Исходный код вики Kafka console tool
Редактировал(а) Alexandr Fokin 2024/05/07 18:41
Последние авторы
| author | version | line-number | content |
|---|---|---|---|
| 1 | |(% style="width:153px" %) |(% style="width:1332px" %)Для взаимодействия с ApacheKafka можно использовать консольную утилиту. | ||
| 2 | Управляющие скрипты распологаются в папках: | ||
| 3 | kafka_2.12-2.4.0\bin\ | ||
| 4 | kafka_2.12-2.4.0\bin\windows | ||
| 5 | |(% style="width:153px" %)Ссылки на вопросы и материалы|(% style="width:1332px" %)((( | ||
| 6 | kafka console tools | ||
| 7 | https://riptutorial.com/apache-kafka/topic/8990/kafka-console-tools | ||
| 8 | |||
| 9 | https://medium.com/@TimvanBaarsen/apache-kafka-cli-commands-cheat-sheet-a6f06eac01b | ||
| 10 | |||
| 11 | Apache Kafka Command Line Interface (CLI) | ||
| 12 | https://howtoprogram.xyz/2016/07/08/apache-kafka-command-line-interface/ | ||
| 13 | |||
| 14 | Configure properties for Apache Kafka® toolbox | ||
| 15 | https://help.aiven.io/en/articles/2661525-viewing-and-resetting-consumer-group-offsets | ||
| 16 | |||
| 17 | |||
| 18 | Kafka consumer list | ||
| 19 | https://stackoverflow.com/questions/32697999/kafka-consumer-list | ||
| 20 | |||
| 21 | kafka get partition count for a topic | ||
| 22 | https://stackoverflow.com/questions/35437681/kafka-get-partition-count-for-a-topic | ||
| 23 | |||
| 24 | Apache Kafka: consumer state | ||
| 25 | https://stackoverflow.com/questions/14755030/apache-kafka-consumer-state | ||
| 26 | |||
| 27 | Kafka - Consumer group creation with specific offset? | ||
| 28 | https://stackoverflow.com/questions/28156227/kafka-consumer-group-creation-with-specific-offset | ||
| 29 | ))) | ||
| 30 | |(% style="width:153px" %) |(% style="width:1332px" %){{code language="cmd"}}Список топиков | ||
| 31 | kafka-topics.bat --bootstrap-server <server> --list | ||
| 32 | |||
| 33 | Консольный consumer | ||
| 34 | kafka-console-consumer.bat --bootstrap-server <server> --topic <topic> --from-beginning | ||
| 35 | |||
| 36 | Данные по ConsumerGroup(текущее смещение) | ||
| 37 | kafka-consumer-groups.bat --describe --group <ConsumerGroupId> --bootstrap-server <server> | ||
| 38 | |||
| 39 | Удалить ConsumerGroup(смещения по группе) | ||
| 40 | kafka-consumer-groups.bat --bootstrap-server <server> --delete --group <ConsumerGroupId>{{/code}} |