1.kafka启动命令
nohup bin/kafka-server-start.sh config/server.properties &
2.创建topic
bin/kafka-topics.sh --create --zookeeper 10.0.178.210:2181 --replication-factor 1 --partitions 1 --topic yddpi_dlcd
3.列出所有Topic
bin/kafka-topics.sh --list --zookeeper 10.0.178.210:2181
4.查看topic详情
bin/kafka-topics.sh --describe --zookeeper 10.0.178.210:2181/lyb --topic TEST_03
5.kafka生产命令行
bin/kafka-console-producer.sh --broker-list 10.0.178.209:9092 --topic yddpi
6.kafka消费命令行
bin/kafka-console-consumer.sh --zookeeper 10.0.178.210:2181 --topic yddpi