Kafka基礎——經常使用命令行

經常使用命令

查看當前服務器中的全部 topic

bin/kafka-topics.sh --zookeeper localhost:2181 --list

建立 topic

bin/kafka-topics.sh --zookeeper localhost:2181 --create --replication-factor 3 --partitions 1 --
topic first

選項說明：

--topic 定義 topic 名
--replication-factor 定義副本數
--partitions 定義分區數

刪除topic

bin/kafka-topics.sh --zookeeper localhost:2181 --delete --topic first

須要 server.properties 中設置 delete.topic.enable=true 不然只是標記刪除。

查看某個 Topic 的詳情

bin/kafka-topics.sh --zookeeper 
localhost:2181 --describe --topic first

修改分區數

bin/kafka-topics.sh --zookeeper localhost:2181 --alter --topic first --partitions 6

發送消息

bin/kafka-console-producer.sh --broker-list localhost:2181 --topic first

消費消息

bin/kafka-console-consumer.sh \--zookeeper localhost:2181 --topic first

bin/kafka-console-consumer.sh \--bootstrap-server localhost:9092 --topic first

bin/kafka-console-consumer.sh \--bootstrap-server localhost:9092 --from-beginning --topic first

--bootstrap-server 指定了鏈接Kafka集羣的地址