Исходный код вики 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}} |