ちょいと業務でKafkaをいじる機会がありまして。
一端、壮絶に備忘録。今度、落ち着いたらまとめまふ。
Topicの一覧
bin/kafka-topics.sh --list --zookeeper localhost:2181
Topicの作成と削除
bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 5 --topic test bin/kafka-topics.sh --delete --zookeeper localhost:2181 --topic test
データ投入(多分、コンソールでstdinから)
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test
受信の確認(--from-beginning つけると多分「保持している内容を初めから全部」的な感じ)
bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic test --from-beginning