FAQ-KAFKA常用指令信息

功能说明

适用模块

kafka

具体说明

常用kafka指令:创建topiclist topic信息,消费数据,生产数据

使用示例

1.创建topic
bin/kafka-topics.sh --zookeeper 172.16.5.151,172.16.5.152,172.16.5.153:2181/kafka_0.11 --create --topic test   --replication-factor 2 --partitions 16

2.查看topic清单

bin/kafka-topics.sh --list --zookeeper 172.16.5.151,172.16.5.152,172.16.5.153:2181/kafka_0.11

3.消费数据

bin/kafka-console-consumer.sh --zookeeper 172.16.5.151,172.16.5.152,172.16.5.153:2181/kafka_0.11    --topic 'test'

4.生产数据

bin/kafka-console-producer.sh --broker-list 172.16.5.151:9092,172.16.5.152:9092,172.16.5.153:9092 --topic test --producer.config config/producer.properties

作者:林帅