首先本地將kafka的docker容器鏡像下載到本地并運行：

docker search kafka

docker pull spotify/kafka

docker run --name kafka3 spotify/kafka

docker ps命令，查看tcp端口號：

新建一個graph，使用典型的生產者-消費者模型：將Data Generator生成的數據交給kafka Producer operator；

而Kafka Consumer從kafka producer里讀取出data Generator生成的數據，通過ToString converter，輸出到Terminal Operator上。

kafka producer和consumer使用的broker和topic必須一致：

運行graph，可以看到

要獲取更多Jerry的原創文章，請關注公眾號"汪子熙":

總結

以上是生活随笔為你收集整理的SAP Data Intelligence Modeler里的Kafka Producer和Kafka Consumer的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。