kafka 常用操作命令

1、建立topic（訊息佇列）

kafka-topics.sh

--create 
--zookeeper 192.168.
***.116:2181  /
/你的zookeeper的ip
--topic mydemo                    /
/訊息佇列的名稱
--replication-factor 1            /
/副本數
--partitions 1                    /
/分割槽數

kafka-topics.sh

--zookeeper 192.168.
***.116:2181  /
/你的zookeeper的ip
--list

kafka-console-producer.sh

--topic mydemo                     /
/佇列名字
--broker-list 192.168.
***.116:9092 /
/你的kafka佇列的機器ip

kafka-console-consumer.sh 

--bootstrap-server 192.168.
***.116:9092 
--from
-beginning                   /
/從起始處開始消費
--topic mydemo

kafka-run-

class
.sh kafka.tools.getoffsetshell 
--topic mydemo
--time -1 
--broker-list 192.168.
***.116:9092
--partitions 0

step1 需在server.properties中增加delete.topic.enable=true配置

step2 刪除訊息佇列

kafka-topics.sh 

--delete 
--zookeeper 192.168.
***.116:2181
--topic mydemo

zkcli.sh                /

/進入zookeeper的client模式

ls

/broker/topics

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常用操作命令

nohup bin kafka server start.sh config server.properties 檢視當前伺服器中的所有topic bin kafka topics.sh list zookeeper node1 2181 建立topic bin kafka topics.sh cr...