环境:win10
kafka版本:kafka_2.11-0.10.0.0
zookeeper版本:zookeeper-3.4.11
1. 开启zookeeeper server
cmd下 :
.\bin\zookeeper-server-start.bat. \config\zookeeper.properties
2.开启 kafka-server
cmd下:
.\bin\kafka-server-start.bat .\config\server.properites
3.在jupyter notebook下创建一个test.ipynb
(1) 创建一个生产者producer:
(2)创建一个consumer消费者:
以上是单机版kafka - produce - consumer 模式