Ahora que la biblioteca Golang Kafka (sarama) proporciona capacidad de grupo de consumidores sin ninguna ayuda de biblioteca externa con kafka 10. ¿Cómo puedo obtener el desplazamiento del mensaje actual que está siendo procesado por un grupo de consumidores en un momento dado?

Anteriormente usaba kazoo-go (https://github.com/wvanbergen/kazoo-go) para compensar el mensaje de mi grupo de consumidores, ya que está almacenado en Zookeeper. Ahora uso sarama-cluster (https://github.com/bsm/sarama-cluster), No estoy seguro de qué API usar para compensar el mensaje de mi grupo de consumidores.