首先本地将kafka的docker容器镜像下载到本地并运行：
docker search kafka
SAP Data Intelligence Modeler里的Kafka Producer和Kafka Consumer docker pull spotify/kafka
SAP Data Intelligence Modeler里的Kafka Producer和Kafka Consumer docker run --name kafka3 spotify/kafka
SAP Data Intelligence Modeler里的Kafka Producer和Kafka Consumer docker ps命令，查看tcp端口号：
SAP Data Intelligence Modeler里的Kafka Producer和Kafka Consumer 新建一个graph，使用典型的生产者-消费者模型：将Data Generator生成的数据交给kafka Producer operator；
而Kafka Consumer从kafka producer里读取出data Generator生成的数据，通过ToString converter，输出到Terminal Operator上。
SAP Data Intelligence Modeler里的Kafka Producer和Kafka Consumer SAP Data Intelligence Modeler里的Kafka Producer和Kafka Consumer kafka producer和consumer使用的broker和topic必须一致：
SAP Data Intelligence Modeler里的Kafka Producer和Kafka Consumer SAP Data Intelligence Modeler里的Kafka Producer和Kafka Consumer 运行graph，可以看到
SAP Data Intelligence Modeler里的Kafka Producer和Kafka Consumer SAP Data Intelligence Modeler里的Kafka Producer和Kafka Consumer 要获取更多Jerry的原创文章，请关注公众号"汪子熙":
SAP Data Intelligence Modeler里的Kafka Producer和Kafka Consumer 
