kafka操作命令

2021-08-21 08:08:20 字數 990 閱讀 8870

啟動:

bin/kafka-server-start.sh -daemon config/server-0.properties

bin/kafka-server-start.sh -daemon config/server-1.properties (如果有多個server/broker)

bin/kafka-server-start.sh -daemon config/server-2.properties (如果有多個server/broker)

停止:bin/kafka-server-stop.sh

檢視已經建立的topic列表:

bin/kafka-topics.sh –list –zookeeper 192.168.0.9:2181

建立topic:

bin/kafka-topics.sh –create –zookeeper 192.168.0.9:2181 –replication-factor 1 –partitions 1 –topic test

檢視topic明細:

bin/kafka-topics.sh –describe –zookeeper 192.168.0.9:2181 –topic test

修改topic引數:

bin/kafka-topics.sh –zookeeper 192.168.0.9:2181 –partition 4 –topic test –alter

刪除topic:

bin/kafka-topics.sh –zookeeper 192.168.0.9:2181 –delete –topic test

永久刪除topic:

刪除kafka儲存目錄(server.properties檔案log.dirs配置,預設為」/tmp/kafka-logs」)相關topic目錄

刪除zookeeper 「/brokers/topics/」目錄下相關topic節點

cd /usr/lib/zookeeper,或 cd

kafka操作命令

kafka server start.bat config server.properties kafka topics.bat create zookeeper localhost 2181 replication factor 1 partitions 2 topic tm tongji kaf...

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...