首先本地将kafka的docker容器镜像下载到本地并运行:
docker search kafka
![](https://img.haomeiwen.com/i2085791/7351307adfd8d7fb.png)
docker pull spotify/kafka
![](https://img.haomeiwen.com/i2085791/bdfe4f096cf30b87.png)
docker run --name kafka3 spotify/kafka
![](https://img.haomeiwen.com/i2085791/56d57bfa010c1582.png)
docker ps命令,查看tcp端口号:
![](https://img.haomeiwen.com/i2085791/c01ede84d63b3c36.png)
新建一个graph,使用典型的生产者-消费者模型:将Data Generator生成的数据交给kafka Producer operator;
而Kafka Consumer从kafka producer里读取出data Generator生成的数据,通过ToString converter,输出到Terminal Operator上。
![](https://img.haomeiwen.com/i2085791/5f44c5e8761254b2.png)
![](https://img.haomeiwen.com/i2085791/a2666cc71c5469b4.png)
kafka producer和consumer使用的broker和topic必须一致:
![](https://img.haomeiwen.com/i2085791/2ac6cfd8875d6e72.png)
![](https://img.haomeiwen.com/i2085791/bffc241a8d0b1ca9.png)
运行graph,可以看到
![](https://img.haomeiwen.com/i2085791/4d2a18fc23c44bb2.png)
![](https://img.haomeiwen.com/i2085791/8a6bebe3f2c3ab42.png)
要获取更多Jerry的原创文章,请关注公众号"汪子熙":
![](https://img.haomeiwen.com/i2085791/fc7ecd97deb67090.png)
网友评论