nohup bin/kafka-server-start.sh config/server.properties &
檢視當前伺服器中的所有topic
bin/kafka-topics.sh --list --zookeeper node1:2181
建立topic
bin/kafka-topics.sh --create --zookeeper node1:2181 --replication-factor 1 --partitions 1 --topic test
刪除topic
bin/kafka-topics.sh --delete --zookeeper node1:2181 --topic test
需要server.properties中設定delete.topic.enable=true否則只是標記刪除或者直接重啟。
通過shell命令傳送訊息(測試)
bin/kafka-console-producer.sh --broker-list node1:9092 --topic test1
通過shell消費訊息(測試)
bin/kafka-console-consumer.sh --zookeeper node1:2181 --from-beginning --topic test1
檢視消費位置
bin/kafka-run-class.sh kafka.tools.consumeroffsetchecker --zookeeper node1:2181 --group testgroup
檢視某個topic的詳情
bin/kafka-topics.sh --topic test --describe --zookeeper node1:2181
對分割槽數進行修改
bin/kafka-topics.sh --zookeeper node1 --alter --partitions 15 --topic utopic
kafka常用操作命令
broker kafka集群由乙個或多個伺服器組成。每個伺服器稱為 主題 topic 維護一組訊息分類 分割槽 partition 隸屬於主題，每個主題會包含多個分割槽，訊息 msg 隸屬於分割槽，每個分割槽有乙個訊息序列，每個訊息在該分割槽中都有乙個唯一的序號，這個序號叫偏移量 生產者 produ...
Kafka常用操作命令
建立主題 kafka topics create bootstrap server node01 9092 replication factor 3 partitions 3 topic test檢視主題列表 kafka topics list bootstrap server node01 909...
kafka 常用操作命令
1 建立topic 訊息佇列 kafka topics.sh create zookeeper 192.168.116 2181 你的zookeeper的ip topic mydemo 訊息佇列的名稱 replication factor 1 副本數 partitions 1 分割槽數2 檢查佇列是...