Hi all,
I am using Kafka admin client to query consumer group partition offsets
(committed and latest) using the below code:
Map<TopicPartition, OffsetAndMetadata> offsets =
admin.listConsumerGroupOffsets(CONSUMER_GROUP)
.partitionsToOffsetAndMetadata().get();
Map<TopicPartition, OffsetSpec> requestLatestOffsets = new HashMap<>();
for(TopicPartition tp: offsets.keySet()) {
requestLatestOffsets.put(tp, OffsetSpec.latest());
}
Map<TopicPartition, ListOffsetsResult.ListOffsetsResultInfo> latestOffsets =
admin.listOffsets(requestLatestOffsets).all().get();
During rebalance of the consumer group (e.g., say a consumer is joining the
group) does the admin API blocks until the rebalance completes? Or does it just
return whatever information on the consumer group members/offset is present at
the request time? I am sying some zero values for the offsets
(latest/committed), when I programmatically add a consumer and after few
seconds (3-4) query for the offsets.
Thank you.
