Есть ли какой-либо Java Api в Kafka, который дает мне список всех групп потребителей вместе с темой/разделом, из которого они потребляют. Кроме того, есть ли способ получить список зоопарков со стороны сервера kafka. Примечание. Я могу получить вышеуказанную информацию от Zookeeper. Но я хочу получить его с сервера Kafka. Не могли бы вы помочь мне в этом!!
Заранее спасибо!!
Вы можете использовать команду kafka-consumer-groups.sh. Это перечислит группы потребителей.
./kafka-consumer-groups.sh --list --bootstrap-server localhost:9092
Когда вы откроете этот скрипт, вы увидите следующее.
if [ "x$KAFKA_HEAP_OPTS" = "x" ]; then
export KAFKA_HEAP_OPTS="-Xmx512M"
fi
exec $(dirname $0)/kafka-run-class.sh kafka.tools.ConsoleConsumer "$@"
Для окон,
"%~dp0kafka-run-class.bat" kafka.admin.ConsumerGroupCommand %*
В Github вы можете увидеть код для ConsumerGroupCommand.
Я думаю, вы можете использовать эти API.
P.S.
Я не знаю о вашем другом вопросе:
Кроме того, есть ли способ получить список зоопарков со стороны сервера kafka?
(думаю нет, может быть?)
