Как получить смещения групп потребителей для раздела в Golang Kafka 10
Теперь, когда библиотека Golang Kafka (sarama) предоставляет возможность группам потребителей без какой-либо внешней помощи библиотеки с помощью kafka 10. Как я могу получить смещение текущего сообщения, обрабатываемое группой потребителей в любой момент времени?
Раньше я пользовался kazoo-go (https://github.com/wvanbergen/kazoo-go), чтобы получить смещение сообщения группы потребителей, как оно хранится в Zookeeper. Теперь я использую Сарама-кластер (https://github.com/bsm/sarama-cluster), Я не уверен, какой API использовать для получения смещения сообщения группы потребителей.