Kafka - команда для получения текущего смещения, совершенного этим потребителем

Question

Я просматриваю документацию и не нашел другого способа получить текущее зафиксированное смещение для каждого раздела текущего потребителя, группы потребителей, кроме использования «подтвержденного» метода.

Есть простой способ , команда, чтобы узнать такое же зафиксированное смещение потребителя?

Answer 1

Вы можете использовать инструмент Kafka, как описано в документации проверка позиции потребителя

> bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092 --describe --group my-group