linux下kafka经常使用命令

先进入到kafka的bin目录下

1.查看topic 列表

./kafka-topics.sh --zookeeper 10.42.123.183:2181 --list

2.建立topic

./kafka-topics.sh --zookeeper 10.42.123.183:2181 --create --topic kfcs --partitions 1 --replication-factor 1

3.启动生产者端

./kafka-console-producer.sh --broker-list 127.0.0.1:9092 --topic kfcs

4.启动消费者端

./kafka-console-consumer.sh --zookeeper 10.42.123.183:2181 --topic kfcs --from-beginning