基于kafka_2.11-2.1.0实现的生产者和消费者代码样例

1、搭建部署好zookeeper集群和kafka集群，这里省略。 1 启动zk： 2 bin/zkServer.sh start conf/zoo.cfg。 3 验证zk是否启动成功： 4 bin/zkServer.sh status conf/zoo.cfg。 5 启动kafka： 6 bin/kafka-server-start.sh -daemon config/server.propert

>>阅读原文<<