# Kafka ## 注意事項 一定要先啟動Zookeeper再啟動Kafka，順序不可以改變。 關閉的話需要先關閉Kafka，在關閉Zookeeper。其次啟動命令建議加上-daemon，后臺運行。 ## 常用命令 ### 啟動關閉相關 ``` 啟動zk： ./bin/zookeeper-server-start.sh -daemon config/zookeeper.properties 啟動Kafka： ./bin/kafka-server-start.sh -daemon config/server.properties 停止Kafka： ./bin/kafka-server-stop.sh 停止zk： ./bin/zookeeper-server-stop.sh ``` ### topic相關 ``` 創建名為test的topic： ./bin/kafka-topics.sh -zookeeper localhost:2181 --create --partitions 5 --replication-factor 1 --topic test -partitions：分區數 -replication-factor：副本數 查詢topic列表： bin/kafka-topics.sh --list --zookeeper localhost:2181 刪除名為test的topic： bin/kafka-topics.sh --delete --zookeeper localhost:2181 --topic test 查詢topic信息： bin/kafka-topics.sh --describe --zookeeper localhost:2181 --topic test 如果未指定topic，則輸出所有topic的信息 增加partition數量（不允許減少）： ./bin/kafka-topics.sh --zookeeper 127.0.0.1:2181 --alter --topic test --partitions 10 ``` ### 消息相關 ``` 生產者發送消息： bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test 消費者查詢消息： bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning --group t1 –from-beginning：表示從頭開始接收數據 –group：指定消費者組 查詢名為test的Topic消息： bin/kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list localhost:9092 --topic test --time -1 –time-1 表示要獲取指定 topic 所有分區當前的最大位移（歷史總消息數），–time-2 表示獲取當前最早位移（被消費的消息數），兩個命令的輸出結果相減便可得到所有分區當前的消息總數。 第一個數字表示分區，第二個數字表示偏移量。 ```