Hi Mazen,
We'll check if the exception returned from brokers is retriable exceptions,
if yes, we'll keep retrying until request timeout(default 30 seconds). Some
retriable exceptions like: NOT_COORDINATOR, COORDINATOR_NOT_AVAILABLE,
LEADER_NOT_AVAILABLE,...
Thanks.
Luke
On Thu, Aug 5, 2021 at 4:1
Hi all,
I am using Kafka admin client to query consumer group partition offsets
(committed and latest) using the below code:
Map offsets =
admin.listConsumerGroupOffsets(CONSUMER_GROUP)
.partitionsToOffsetAndMetadata().get();
Map requestLatestOffsets = new HashMap<>();
for(TopicPartition tp:
