備忘録：kafkaのシェルコマンド

このページは備忘録です。
たまにアップデートされていくと思います。

kafka brokerのconfigを見る

kafka-configs.sh --bootstrap-server kafka.default.svc.cluster.local:9092 --entity-type brokers --describe --all

topicの一覧をlistで出す

kafka-topics.sh --bootstrap-server kafka.default.svc.cluster.local:9092 --list

kafkaのtopicの情報を見る

kafka-topics.sh --bootstrap-server kafka.default.svc.cluster.local:9092 --topic [topic名] --describe

kafkaのProducerでメッセージを送信する

kafka-console-producer.sh --broker-list kafka-0.kafka-headless.default.svc.cluster.local:9092,kafka-1.kafka-headless.default.svc.cluster.local:9092,kafka-2.kafka-headless.default.svc.cluster.local:9092 --topic [topic名]

kafkaのConsumerでメッセージを受信する

kafka-console-consumer.sh --bootstrap-server kafka.default.svc.cluster.local:9092 --topic [topic名] --from-beginning