Kafka的幾個常用指令

叢集中建立主題

bin/kafka-topics.sh --create --zookeeper 192.168.1.201:2181,192.168.1.202:2181,92.168.1.203:2181 --replication-factor 3 --partitions 3 --topic jackTopic

叢集中檢視主題

bin/kafka-topics.sh --list --zookeeper 192.168.1.201:2181,192.168.1.202:2181,92.168.1.203:2181

生産者

bin/kafka-console-producer.sh --broker-list 192.168.0.130:9092,192.168.0.131:9092,192.168.0.132:9092 --topic topicTest

消費者

bin/kafka-console-consumer.sh --bootstrap-server 192.168.1.201:9092,192.168.1.202:9092,192.168.1.203:9092 --topic jackTopic

表示從 latest 位移位置開始消費該主題的所有分區消息，即僅消費正在寫入的消息

從開始位置消費

bin/kafka-console-consumer.sh --bootstrap-server 192.168.1.201:9092,192.168.1.202:9092,192.168.1.203:9092 --from-beginning --topic jackTopic

表示從指定主題中有效的起始位移位置開始消費所有分區的消息。

顯示key消費

bin/kafka-console-consumer.sh --bootstrap-server 192.168.1.201:9092,192.168.1.202:9092,192.168.1.203:9092 --property print.key=true --topic jackTopic

消費出的消息結果将列印出消息體的key和value