kafka 常用操作

kafka支援的基本命令位於$/bin資料夾中

常用命令：

kafka-topics.shkafka-console-consumer.shkafka-console-producer.sh

kafka命令參考頁面: kafka-0.8.x-幫助文件

# 檢視topic列表

kafka-topics --list --zookeeper zkip:2181
# 建立topic
kafka-topics --create --zookeeper zkip:2181 --topic topic_name
# 建立topic 指定複製因子為2, partitions為3
kafka-topics --create --zookeeper zkip:2181 --replication-factor 2 --partitions 3 --topic topic_name
# 刪除topic
kafka-topics --delete --zookeeper zkip:2181 --topic topic_name
# 修改topic
kafka-topics --alter --zookeeper zkip:2181 --partitions 4 --topic topic_name

# 消費topic

kafka-console-consumer --zookeeper zkip:2181 --topic topic_name 
# 重頭消費topic
kafka-console-consumer --zookeeper zkip:2181 --topic topic_name --from-beginning

# 傳送資料到topic

kafka-console-producer --broker-list kafka_broker_ip:9092 --topic topic_name

# 檢視消費組資訊

kafka-consumer-groups.sh --bootstrap-server kafka_broker_ip:9092 --describe --group test-group1

kafka常用操作

1.開啟zookeeper命令 備註 先進入zookeeper的bin目錄 zkserver.sh start 2.關閉zookeeper命令 備註 先進入zookeeper的bin目錄 zkserver.sh stop 3.kafka啟動命令 備註 先進入kafka目錄 常規模式啟動kafka b...

Kafka常用操作

1.kafka監控 kafka manager 2.啟動kafka 啟動zookeeper bin zkserver.sh start 開啟zk客戶端查詢 bin zkcli.sh server dsjcx1 2181,dsjcx2 2181,dsjcx3 2181 啟動kafka bin kafk...

kafka常用操作命令

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