启动Kakfa
/home/app/kafka/bin/kafka-server-start.sh -daemon /home/app/kafka/config/server.properties
建topic
./kafka-topics.sh --create --zookeeper 10.4.1.1:2181 --topic aaa_topic_1 --partitions 5 --replication-factor 3
查看topic
./kafka-topics.sh --zookeeper 10.4.1.1:2181 --list
手工生产消息
./kafka-console-producer.sh --broker-list 10.4.1.1:9092 --topic aaa_topic_1
手工消费消息
./kafka-console-consumer.sh --bootstrap-server 10.4.1.1:9092 --topic aaa_topic_1