基於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

>>阅读原文<<