diff --git a/clients/src/main/java/org/apache/kafka/clients/admin/ConsumerGroupDescription.java b/clients/src/main/java/org/apache/kafka/clients/admin/ConsumerGroupDescription.java index bc3857d7aea..933d66ca4b7 100644 --- a/clients/src/main/java/org/apache/kafka/clients/admin/ConsumerGroupDescription.java +++ b/clients/src/main/java/org/apache/kafka/clients/admin/ConsumerGroupDescription.java @@ -37,12 +37,12 @@ public class ConsumerGroupDescription { private final ConsumerGroupState state; private final Node coordinator; - ConsumerGroupDescription(String groupId, - boolean isSimpleConsumerGroup, - Collection members, - String partitionAssignor, - ConsumerGroupState state, - Node coordinator) { + public ConsumerGroupDescription(String groupId, + boolean isSimpleConsumerGroup, + Collection members, + String partitionAssignor, + ConsumerGroupState state, + Node coordinator) { this.groupId = groupId == null ? "" : groupId; this.isSimpleConsumerGroup = isSimpleConsumerGroup; this.members = members == null ? Collections.emptyList() : diff --git a/clients/src/main/java/org/apache/kafka/clients/admin/MemberAssignment.java b/clients/src/main/java/org/apache/kafka/clients/admin/MemberAssignment.java index 6c180ad574d..8765c17d984 100644 --- a/clients/src/main/java/org/apache/kafka/clients/admin/MemberAssignment.java +++ b/clients/src/main/java/org/apache/kafka/clients/admin/MemberAssignment.java @@ -34,7 +34,7 @@ public class MemberAssignment { * * @param topicPartitions List of topic partitions */ - MemberAssignment(Set topicPartitions) { + public MemberAssignment(Set topicPartitions) { this.topicPartitions = topicPartitions == null ? Collections.emptySet() : Collections.unmodifiableSet(new HashSet<>(topicPartitions)); } diff --git a/clients/src/main/java/org/apache/kafka/clients/admin/MemberDescription.java b/clients/src/main/java/org/apache/kafka/clients/admin/MemberDescription.java index 895abadfdb8..a8865bed0ee 100644 --- a/clients/src/main/java/org/apache/kafka/clients/admin/MemberDescription.java +++ b/clients/src/main/java/org/apache/kafka/clients/admin/MemberDescription.java @@ -31,7 +31,7 @@ public class MemberDescription { private final String host; private final MemberAssignment assignment; - MemberDescription(String memberId, String clientId, String host, MemberAssignment assignment) { + public MemberDescription(String memberId, String clientId, String host, MemberAssignment assignment) { this.memberId = memberId == null ? "" : memberId; this.clientId = clientId == null ? "" : clientId; this.host = host == null ? "" : host;