diff --git a/clients/src/main/java/org/apache/kafka/clients/consumer/ConsumerGroupMetadata.java b/clients/src/main/java/org/apache/kafka/clients/consumer/ConsumerGroupMetadata.java index 4ba53ae38226a..bae0746a33ba9 100644 --- a/clients/src/main/java/org/apache/kafka/clients/consumer/ConsumerGroupMetadata.java +++ b/clients/src/main/java/org/apache/kafka/clients/consumer/ConsumerGroupMetadata.java @@ -31,6 +31,10 @@ public class ConsumerGroupMetadata { private final String memberId; private final Optional groupInstanceId; + /** + * @deprecated Since 4.1, please use {@link KafkaConsumer#groupMetadata()} instead. This class will be an interface in Kafka 5.0. + */ + @Deprecated public ConsumerGroupMetadata(String groupId, int generationId, String memberId, @@ -41,6 +45,10 @@ public ConsumerGroupMetadata(String groupId, this.groupInstanceId = Objects.requireNonNull(groupInstanceId, "group.instance.id can't be null"); } + /** + * @deprecated Since 4.1, please use {@link KafkaConsumer#groupMetadata()} instead. This class will be an interface in Kafka 5.0. + */ + @Deprecated public ConsumerGroupMetadata(String groupId) { this(groupId, JoinGroupRequest.UNKNOWN_GENERATION_ID,