SAP Data Intelligence Modeler裡的Kafka Producer和Kafka Consumer

首先本地将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，可以看到

本文來自雲栖社群合作夥伴“汪子熙”，了解相關資訊可以關注微信公衆号"汪子熙"。