Kafka console tool

Редактировал(а) Alexandr Fokin 2024/05/07 18:41
 Для взаимодействия с ApacheKafka можно использовать консольную утилиту.
Управляющие скрипты распологаются в папках:
kafka_2.12-2.4.0\bin\
kafka_2.12-2.4.0\bin\windows
Ссылки на вопросы и материалы

kafka console tools
https://riptutorial.com/apache-kafka/topic/8990/kafka-console-tools

https://medium.com/@TimvanBaarsen/apache-kafka-cli-commands-cheat-sheet-a6f06eac01b

Apache Kafka Command Line Interface (CLI)
https://howtoprogram.xyz/2016/07/08/apache-kafka-command-line-interface/

Configure properties for Apache Kafka® toolbox
https://help.aiven.io/en/articles/2661525-viewing-and-resetting-consumer-group-offsets

Kafka consumer list
https://stackoverflow.com/questions/32697999/kafka-consumer-list

kafka get partition count for a topic
https://stackoverflow.com/questions/35437681/kafka-get-partition-count-for-a-topic

Apache Kafka: consumer state
https://stackoverflow.com/questions/14755030/apache-kafka-consumer-state

Kafka - Consumer group creation with specific offset?
https://stackoverflow.com/questions/28156227/kafka-consumer-group-creation-with-specific-offset

 Список топиков
kafka-topics.bat --bootstrap-server <server> --list

Консольный consumer
kafka-console-consumer.bat --bootstrap-server <server> --topic <topic> --from-beginning

Данные по ConsumerGroup(текущее смещение)
kafka-consumer-groups.bat --describe --group <ConsumerGroupId> --bootstrap-server <server>

Удалить ConsumerGroup(смещения по группе)
kafka-consumer-groups.bat --bootstrap-server <server> --delete --group <ConsumerGroupId>
Теги: