Kafka常用操作命令

建立主題

kafka-topics --create --bootstrap-server node01:9092 --replication-factor 3 --partitions 3 --topic test

kafka-topics --list --bootstrap-server node01:9092

檢視某個主題詳情

kafka-topics --topic test --describe --bootstrap-server node01:9092

刪除主題

kafka-topics --delete --bootstrap-server node01:9092 --topic test

控制台啟動生產者

kafka-console-producer --broker-list node01:9092 --topic test

kafka-console-consumer --bootstrap-server node01:9092 --topic test --from-beginning

修改分割槽數

kafka-topics --bootstrap-server node01:9092 --alter --partitions 6 --topic utopic

kafka常用操作命令

broker kafka集群由乙個或多個伺服器組成。每個伺服器稱為 主題 topic 維護一組訊息分類 分割槽 partition 隸屬於主題，每個主題會包含多個分割槽，訊息 msg 隸屬於分割槽，每個分割槽有乙個訊息序列，每個訊息在該分割槽中都有乙個唯一的序號，這個序號叫偏移量 生產者 produ...

kafka 常用操作命令

1 建立topic 訊息佇列 kafka topics.sh create zookeeper 192.168.116 2181 你的zookeeper的ip topic mydemo 訊息佇列的名稱 replication factor 1 副本數 partitions 1 分割槽數2 檢查佇列是...

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