现在,golang kafka图书馆(sarama)正在提供消费群体功能,而无需任何外部图书馆帮助kafka 10。如何获取消费者组在任何给定时间处理的当前消息偏移量?
以前我用kazoo go(https://github.com/wvanbergen/kazoo-go)以获取存储在zookeeper中的消费者组消息偏移量。现在我使用sarama集群(https://github.com/bsm/sarama-cluster),我不确定使用哪个api来获取我的消费群消息偏移量。
现在,golang kafka图书馆(sarama)正在提供消费群体功能,而无需任何外部图书馆帮助kafka 10。如何获取消费者组在任何给定时间处理的当前消息偏移量?
以前我用kazoo go(https://github.com/wvanbergen/kazoo-go)以获取存储在zookeeper中的消费者组消息偏移量。现在我使用sarama集群(https://github.com/bsm/sarama-cluster),我不确定使用哪个api来获取我的消费群消息偏移量。
1条答案
按热度按时间sshcrbum1#
我也在和萨拉玛和Kafka合作,以抵消一个主题。
你可以用下面的代码得到偏移量。
让我知道如果这是你正在寻找的答案,如果它是有用的。