Общее
bin/kafka-configs.sh --bootstrap-server kafka-kafka-brokers:9092 --describe --entity-type brokers --entity-name 0
bin/kafka-topics.sh --bootstrap-server kafka-kafka-brokers:9092 --list
Диагностика
bin/kafka-topics.sh --bootstrap-server kafka-kafka-brokers:9092 --under-min-isr-partitions --describe
bin/kafka-topics.sh --bootstrap-server kafka-kafka-brokers:9092 --replicated-partitions —list
bin/kafka-consumer-groups.sh --bootstrap-server kafka-kafka-brokers:9092 --group theclub-comsumer-id --describe
Работа с топиком
bin/kafka-topics.sh --bootstrap-server kafka-kafka-brokers:9092 --describe --topic <topic_name>
bin/kafka-console-consumer.sh --bootstrap-server kafka-kafka-brokers:9092 --topic <topic_name> --from-beginning
bin/kafka-topics.sh --bootstrap-server kafka-kafka-brokers:9092 --delete --topic <topic_name>
delete.topic.enable=true
на strimzi-operator включено везде по дефолту = 1
bin/kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list kafka-kafka-brokers:9092 --topic top-lak-source-topic --time -2
bin/kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list kafka-kafka-brokers:9092 --topic top-lak-source-topic --time -1
/usr/bin/shuf -i 1-1000 -n 30000 | tee -a /tmp/kafka-random-data | bin/kafka-console-producer.sh --bootstrap-server=kafka-kafka-brokers:9092 --topic top-lak-source-topic
и вводить..
for i in {1..10};do echo $i | bin/kafka-console-producer.sh --bootstrap-server=kafka-kafka-brokers:9092 --topic top-lak-source-topic; done;
bin/kafka-console-producer.sh --broker-list kafka-kafka-brokers:9092 --topic top-lak-source-topic
cat /tmp/cat.txt | bin/kafka-console-producer.sh --broker-list kafka-kafka-brokers:9092 --topic top-lak-source-topic
bin/kafka-consumer-groups.sh --bootstrap-server kafka-kafka-brokers:9092 --group top-lak-comsumer-id --reset-offsets --shift-by 67437 --topic top-lak-source-topic --execute
Переезд топиков
kafkacat -b localhost:9092 -C -t source-topic -K: -e -o beginning | kafkacat -b localhost:9092 -P -t target-topic -K:
kafkacat -b localhost:9092 -C -t source-topic -K: -e -o beginning | kafkacat -b localhost:9093 -P -t source-topic -K:
обслуживание кластера
kubectl annotate pod kafka-zookeeper-2 strimzi.io/delete-pod-and-pvc=true -n kafka