如何解析SAPDataIntelligenceModeler里的KafkaProducer和KafkaConsumer

这篇文章将为大家详细讲解有关如何解析SAP Data Intelligence Modeler里的Kafka Producer和Kafka Consumer，文章内容质量较高，因此小编分享给大家做个参考，希望大家阅读完这篇文章后对相关知识有一定的了解。

专注于为中小企业提供成都做网站、成都网站设计服务,电脑端+手机端+微信端的三站合一,更高效的管理,为中小企业凌海免费做网站提供优质的服务。我们立足成都，凝聚了一批互联网行业人才，有力地推动了上千多家企业的稳健成长，帮助中小企业通过网站建设实现规模扩充和转变。

首先本地将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

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

如何解析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就分享到这里了，希望以上内容可以对大家有一定的帮助，可以学到更多知识。如果觉得文章不错，可以把它分享出去让更多的人看到。

文章标题：如何解析SAPDataIntelligenceModeler里的KafkaProducer和KafkaConsumer
转载源于：http://csdahua.cn/article/jeceee.html

扫二维码与项目经理沟通

我们在微信上24小时期待你的声音

解答本文疑问/技术咨询/运营咨询/技术建议/互联网交流

其他资讯