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