Kafka命令操作

本文主要介绍Kafka的shell命令：查看当前服务器所有的topic1[hadoop@datanode1 kafka]$ bin/kafka-topics.sh --zookeeper datanode1:2181 --list创建topic12345[hadoop@datanode1 kafka]$ bin/kafka-topic...

清风笑丶

5752人浏览 · 2018-11-14 17:37:55

清风笑丶 · 2018-11-14 17:37:55 发布

本文主要介绍Kafka的shell命令：

查看当前服务器所有的topic

1	[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

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

创建生产者发送消息

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

创建消费者接受消息

1
2

[hadoop@datanode2 kafka]$ bin/kafka-console-consumer.sh --zookeeper datanode1:2181 --from-beginning --topic test
--from-beginning：会把first主题中以往所有的数据都读取出来。根据业务场景选择是否

查看某一个topic的详情

1
2
3

[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