[TOC] # 文檔 官方文檔：http://kafka.apache.org/documentation.html 中文文檔: http://orchome.com/kafka/index # topic * 查看當前服務器中的所有topic ~~~ kafka-topics.sh --list --zookeeper master:2181 ~~~ * 查看topic狀態 ~~~ kafka-topics.sh --describe --zookeeper localhost:2181 --topic order ~~~ * 創建topic ~~~ kafka-topics.sh --create --zookeeper master:2181,slave1:2181,slave2:2181 --replication-factor 1 --partitions 1 --topic order ~~~ ~~~ --replication-factor 1 #復制1份,冗余數 --partitions 1 #創建1個分區 --topic #主題 ~~~ * 刪除topic ~~~ kafka-topics.sh --delete --zookeeper master:2181 --topic order ~~~ 需要server.properties中設置delete.topic.enable=true否則只是標記刪除或者直接重啟。 # 發送消費消息 * 通過shell命令發送消息 ~~~ kafka-console-producer.sh --broker-list master:9092 --topic order ~~~ 注意這里的master:9092和zk沒有關系,這邊是指生產的消息放到哪個kafka集群上運行 **zk中存的是偏移量和broker的狀態信息** * 通過shell消費消息(--from-beginning從最開始的位置消費數據) ~~~ kafka-console-consumer.sh --zookeeper master:2181 --topic order --from-beginning ~~~ # 查看消息 * 查看消費位置 ~~~ kafka-run-class.sh kafka.tools.ConsumerOffsetChecker --zookeeper master:2181 --group testGroup ~~~ * 查看某個Topic的詳情 ~~~ kafka-topics.sh --topic order --describe --zookeeper master:2181 ~~~ # 修改分區 * 對分區數進行修改 ~~~ kafka-topics.sh --zookeeper master --alter --partitions 15 --topic utopic ~~~ # maven的包 ~~~ <!-- https://mvnrepository.com/artifact/org.apache.kafka/kafka-clients --> <dependency> <groupId>org.apache.kafka</groupId> <artifactId>kafka-clients</artifactId> <version>0.11.0.2</version> </dependency> <!-- https://mvnrepository.com/artifact/org.apache.kafka/kafka-streams --> <dependency> <groupId>org.apache.kafka</groupId> <artifactId>kafka-streams</artifactId> <version>0.11.0.2</version> </dependency> <!-- https://mvnrepository.com/artifact/org.apache.kafka/kafka --> <dependency> <groupId>org.apache.kafka</groupId> <artifactId>kafka_2.12</artifactId> <version>0.11.0.0</version> </dependency> ~~~