Kafka命令操做

本文主要介紹Kafka的shell命令：node

查看當前服務器全部的topic

[hadoop@datanode1 kafka]$ bin/kafka-topics.sh --zookeeper datanode1:2181 --list

建立topic

[hadoop@datanode1 kafka]$ bin/kafka-topics.sh --zookeeper datanode1:2181 --create --replication-factor 3 --partitions 1 --topic first
選項說明：
	--topic 定義topic名
	--replication-factor  定義副本數
	--partitions  定義分區數

刪除topic

[hadoop@datanode1 kafka]$ bin/kafka-topics.sh --zookeeper datanode1:2181 --delete --topic first

建立生產者發送消息

[hadoop@datanode1 kafka]$ bin/kafka-console-producer.sh --broker-list datanode1:9092 --topic test

建立消費者接受消息

[hadoop@datanode2 kafka]$ bin/kafka-console-consumer.sh --zookeeper datanode1:2181 --from-beginning --topic test
--from-beginning：會把first主題中以往全部的數據都讀取出來。根據業務場景選擇是否

查看某一個topic的詳情

[hadoop@datanode1 kafka]$ bin/kafka-topics.sh --zookeeper datanode1:2181 --describe --topic test
Topic:test      PartitionCount:1        ReplicationFactor:3     Configs:
Topic: test     Partition: 0    Leader: 2       Replicas: 2,3,1 Isr: 2,3,1