java – 如何获取消费者组的最后消耗偏移量？

我在消费者组中有两个使用相同kafka主题分区的消费者.我想从消费者B内部获得消费者A的最后读取偏移量.任何想法,如何实现这一点？

解决方法:

永远不会将单个分区分配给同一组中的两个使用者实例.

您可以使用以下脚本来了解上次消耗的偏移量

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

标签：java,apache-kafka,kafka-consumer-api
来源： https://codeday.me/bug/20190628/1310506.html