diff --git a/clients/src/main/java/org/apache/kafka/clients/admin/ListShareGroupOffsetsResult.java b/clients/src/main/java/org/apache/kafka/clients/admin/ListShareGroupOffsetsResult.java index 8e28ec015370a..cdcd4075af068 100644 --- a/clients/src/main/java/org/apache/kafka/clients/admin/ListShareGroupOffsetsResult.java +++ b/clients/src/main/java/org/apache/kafka/clients/admin/ListShareGroupOffsetsResult.java @@ -45,7 +45,7 @@ public class ListShareGroupOffsetsResult { /** * Return the future when the requests for all groups succeed. * - * @return - Future which yields all Map objects, if requests for all the groups succeed. + * @return - Future which yields all Map<String, Map<TopicPartition, Long>> objects, if requests for all the groups succeed. */ public KafkaFuture>> all() { return KafkaFuture.allOf(futures.values().toArray(new KafkaFuture[0])).thenApply( @@ -65,7 +65,7 @@ public KafkaFuture>> all() { } /** - * @param groupId - The groupId for which the Map is needed + * @param groupId - The groupId for which the Map<TopicPartition, Long> is needed * @return - Future which yields a map of topic partitions to offsets for the specified group. */ public KafkaFuture> partitionsToOffset(String groupId) {