kafka2.8脫離ZooKeeper

在config目錄下多了一個kraft目錄，在該目錄中有一套新的配置文件，可以直接脫離ZooKeeper運行

 

配置kraft目錄中的server.properties文件

單機的話主要是修改下面的配置

advertised.listeners=PLAINTEXT://localhost:9092

將localhost修改為IP。如果不改為IP，其他服務器連接不上

advertised.listeners=PLAINTEXT://10.10.14.237:9092

 

通過現在三行命令，即可開啟一個單機的broker

/usr/local/kafka/bin/kafka-storage.sh random-uuid

/usr/local/kafka/bin/kafka-storage.sh format -t 1DViwWWpQf63N6bhJFAgzQ -c /usr/local/kafka/config/kraft/server.properties

/usr/local/kafka/bin/kafka-server-start.sh /usr/local/kafka/config/kraft/server.properties

#后台啟動
/usr/local/kafka/bin/kafka-server-start.sh -daemon /usr/local/kafka/config/kraft/server.properties

這樣脫離ZooKeeper的kafka就啟動了，當前版本還是測試階段，所以官方不推薦使用。

 

創建一個topic

/usr/local/kafka/bin/kafka-topics.sh --create --topic test --partitions 3 --replication-factor 1 --bootstrap-server localhost:9092

查看topic信息

/usr/local/kafka/bin/kafka-topics.sh --describe --topic test --bootstrap-server localhost:9092

刪除topic

/usr/local/kafka/bin/kafka-topics.sh --delete --topic test --bootstrap-server localhost:9092

發送

/usr/local/kafka/bin/kafka-console-producer.sh --bootstrap-server localhost:9092 --topic test

接收

/usr/local/kafka/bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning

 查看topic有多少條數據

/usr/local/kafka/bin/kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list localhost:9092 --topic test

 獲取所有topic列表

/usr/local/kafka/bin/kafka-topics.sh --bootstrap-server localhost:9092 --list