Как получить смещения групп потребителей для раздела в Golang Kafka 10

Теперь, когда библиотека Golang Kafka (sarama) предоставляет возможность группам потребителей без какой-либо внешней помощи библиотеки с помощью kafka 10. Как я могу получить смещение текущего сообщения, обрабатываемое группой потребителей в любой момент времени?

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

Ответы на вопрос(1)

Ваш ответ на вопрос