java - How to get last consumed offset for a consumer group? -


i have 2 consumers in consumer group have assigned same kafka topic partitions. wish last read offset of say, consumer inside consumer b. idea, how implement this?

a single partition never assigned 2 consumer instances in same group.

you can use below script know last consumed offset

sh kafka-consumer-groups.sh --bootstrap-server localhost:9092 --new-consumer --group groupname --describe 

Comments