在windows下进行Kafka单机测试

时间:2021-04-19 04:32:44

环境: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:

在windows下进行Kafka单机测试

在windows下进行Kafka单机测试

(2)创建一个consumer消费者:

在windows下进行Kafka单机测试

在windows下进行Kafka单机测试

以上是单机版kafka - produce - consumer 模式