kafka 命令列操作

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

--zookeeper 指定連線zookeeper的位址

--replication-factor 副本因子

--partitions 分割槽數

--topic test topic的名稱

bin/kafka-topics.sh --list --zookeeper m1:2181

bin/kafka-console-producer.sh --broker-list m1:9092 --topic test

--topic 指定topic名稱

bin/kafka-console-consumer.sh --bootstrap-server m1:9092 --topic test --from-beginning

--topic 指定topic名稱

--from-beginning 從頭消費訊息

檢視topic相信資訊

建立多個副本的topic

topic: topic名稱

partitioncount: 分割槽總數

replicationfactor: 副本因子

configs: 訊息相關配置資訊

topic: topic名稱    partition: 分割槽標號，從0開始 leader: 分割槽leader所在的broker id         replicas: 副本所在的 broker id      isr: 還存活的broker id

Kafka命令列操作

1 檢視當前伺服器中的所有topic atguigu hadoop102 kafka bin kafka topics.sh zookeeper hadoop102 2181 list2 建立topic atguigu hadoop102 kafka bin kafka topics.sh zook...

Kafka 命令列操作

1.檢視當前伺服器中的所有 topic bin kafka topics.sh zookeeper localhost 2181 list2.建立 topic bin kafka topics.sh zookeeper localhost 2181 create replication factor...

Kafka命令列操作

1.檢視當前伺服器中的所有topicbin kafka topics.sh zookeeper bigdata13 2181 list2.建立topicbin kafka topics.sh zookeeper bigdata13 2181 create replication factor 3 p...