kafka創建、生產者和消費者的操作命令

# 創建1分區、1備份的topic

./bin/kafka-topics.sh --create --zookeeper ip1:2181,ip2:2181,ip3:2181 --replication-factor 1 --partitions 1 --topic topic_name

# 展示topic
./bin/kafka-topics.sh --list --zookeeper ip1:2181,ip2:2181,ip3:2181

# 查看描述topic
./bin/kafka-topics.sh --describe --zookeeper ip1:2181,ip2:2181,ip3:2181 --topic topic_name

# 生產者發送消息
./bin/kafka-console-producer.sh --broker-list ip1:9092 --topic topic_name

# 消費者消費消息
./bin/kafka-console-consumer.sh --bootstrap-server ip1:9092,ip2:9092,ip3:9092 --topic topic_name

# 刪除topic
./bin/kafka-topics.sh --delete --topictopic_name ip:9092 --topic myTopic --from-beginning --group default_group

 

報錯：

1、Error while fetching metadata with correlation id 1 : {topic_test=LEADER_NOT_AVAILABLE}

消費kafka topic主題的報錯 LEADER_NOT_AVAILABLE

 

 

連接zookeeper（${ZOOKEEPER_HOME}/bin/zkCli.sh -server zkhostname:port）

查看 /controller 節點數據。

 

 

 

 如果結果如上圖一樣，內容為null的話，刪除該znode。然后重啟zookeeper服務

注：zookeeper /controller 節點與kafka 分區的主節點選舉相關，刪除后Kafka會自動重建該節點，並觸發主節點選舉。