---檢視生成和消費佇列的訊息數量
kafka-run-class.bat kafka.tools.consumeroffsetchecker --topic test --zookeeper localhost:2181 --group test1
[img]
topic：建立時topic名稱
partition：分割槽編號
offset：表示該parition已經消費了多少條message
logsize：表示該partition已經寫了多少條message
lag：表示有多少條message沒有被消費。
owner：表示消費者
created：該partition建立時間
last seen：消費狀態重新整理最新時間。
--- 建立標題()
kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test1
--檢視標題列表
kafka-topics.sh --list --zookeeper localhost:2181
--刪除標題
kafka 刪除topic的命令是：
kafka-topics.bat --delete --zookeeper 【zookeeper server】 --topic 【topic name】
如果kafaka啟動時載入的配置檔案中server.properties沒有配置delete.topic.enable=true
，那麼此時的刪除並不是真正的刪除，而是把topic標記為：marked for deletion
[img]
--生產訊息
kafka-console-producer.bat --broker-list localhost:9092 --topic test
kafka-console-producer.bat --broker-list kafka服務ip:9092 --topic 標題
---啟動消費者，檢視資訊
kafka-console-consumer.bat --zookeeper localhost:2181 --topic test --from-beginning
kafka常用命令
kafka常用操作命令 l檢視當前伺服器中的所有topic bin kafka topics.sh list zookeeper hadoop02 2181 l建立topic kafka topics.sh create zookeeper hadoop02 2181 replication fac...
kafka常用命令
啟動集群 nohup bin kafka server start.sh config server.properties 建立topic kafka topics topictt replication factor3 partitions3 create zookeeper hadoop1 21...
Kafka 常用命令
kafka console producer broker list 127.0.0.1 9092 topic mytopic kafka console consumer bootstrap server 127.0.0.1 9092 topic mytopic 建立主題,replication ...