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.

Reply via email to