启动zookeeper

zkServer.sh start

停止zookeeper

zkServer.sh stop

查看zookeeper状态

zkServer.sh status

启动Kafka server

kafka-server-start.sh config/server.properties

创建主题

kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test

查看主题

kafka-topics.sh --list --zookeeper localhost:2181

控制台生产消息

kafka-console-producer.sh --broker-list localhost:9092 --topic test

控制台消费消息

kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning

java maven 客户端，生产数据，消息数据

• https://github.com/opensourceteams/kafka-java-maven/blob/master/md/producter-consumer-example.md