gallu’s blog

エンジニアでゲーマーで講師で占い師なおいちゃんのブログです。

Kafka覚書

ちょいと業務で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