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,可以看到
本文来自云栖社区合作伙伴“汪子熙”,了解相关信息可以关注微信公众号"汪子熙"。
低调大师中文资讯倾力打造互联网数据资讯、行业资源、电子商务、移动互联网、网络营销平台。
持续更新报道IT业界、互联网、市场资讯、驱动更新,是最及时权威的产业资讯及硬件资讯报道平台。
转载内容版权归作者及来源网站所有,本站原创内容转载请注明来源。
- 上一篇
阿里云如何提交工单呼叫人工帮助技术支持的方法
阿里云售后控制台的工单系统提供了完善的技术支持服务,很多用户不清楚如何使用工单系统,云吞铺子分享: 阿里云提交工单的方法 为什么要提交工单?工单可以唤醒人工客服,工单客服拥有更多权限,工单更容易沟通的交流问题,废话少说,如何提交工单,很多用户找不到入口,云吞铺子分享: 打开阿里云联系中心,打开工单控制台如下图所示: 点击“提交工单” 根据自己的问题选择产品分类,例如:咨询售前就选择授权,咨询备案问题就选备案,咨询ECS云服务器技术问题就选ECS等 如上图所示,根据自身实际问题,选择产品分类 比如我遇到ECS云服务器相关问题,我点击“云服务器ECS 提问”如下图所示: 选择一个问题分类,如果你不清楚是属于哪个问题分类,也要随便点一个分类,只有进入问题分类后才能看到“创建工单”选项。比如,我选择“远程连接咨询”如下图所示:看到了吗?“创建工单”选项出来了(只有进入问题分类才能看到创建工单),点击“创建工单” 填写工单信息 如上图所示,填写工单信息,按照实际信息填写即可,可以选择优先级,重要就选择重要,客服会优先处理。例如我选择的是ECS云服务器问题,所以我需要填写服务器IP、实例ID等信息...
- 下一篇
【云栖号案例 | 互联网】驻云科技基于MaxCompute搭建社交好友推荐系统
云栖号案例库:【点击查看更多上云案例】不知道怎么上云?看云栖号案例库,了解不同行业不同发展阶段的上云方案,助力你上云决策! 公司介绍 驻云科技是国内领先的云技术服务提供商,致力于将普惠计算能力落实到每家企业,通过输出多年的云服务经验和能力,帮助企业充分利用云计算和新技术的优势,有效管理和优化其 IT 架构,用数据连接业务,持续创新,助力企业在新时代获得成功。CloudCare 是驻云科技旗下的一站式 IT 服务品牌,通过将多年的云服务经验数字化,结合基于人工智能的云管理协作平台,提供丰富的产品、一系列专家服务、成熟的解决方案,以及云上开发和交付。 大数据在好友推荐系统中的应用 驻云科技基于MaxCompute搭建了社交好友推荐系统,使用MaxCompute阿里的大数据计算的方法在这种场景下可以完成社交好友推荐。现在大家都在讲大数据,如果想去使用这些数据,需要具备三个要素: 海量的数据 数据量越多越好,只有数据量达到了足够大,我们才能从数据中挖掘出来更多有用信息。 处理数据的能力 有了这样很高的快速处理数据的能力,可以让我们更快的去把数据里面的信息挖掘出来。 商业变现的场景 我们采集大数...
相关文章
文章评论
共有0条评论来说两句吧...
文章二维码
点击排行
推荐阅读
最新文章
- CentOS8,CentOS7,CentOS6编译安装Redis5.0.7
- CentOS7,CentOS8安装Elasticsearch6.8.6
- Docker使用Oracle官方镜像安装(12C,18C,19C)
- Jdk安装(Linux,MacOS,Windows),包含三大操作系统的最全安装
- Linux系统CentOS6、CentOS7手动修改IP地址
- CentOS7安装Docker,走上虚拟化容器引擎之路
- CentOS7编译安装Cmake3.16.3,解决mysql等软件编译问题
- SpringBoot2全家桶,快速入门学习开发网站教程
- CentOS7设置SWAP分区,小内存服务器的救世主
- Docker快速安装Oracle11G,搭建oracle11g学习环境