本文介绍了将CometD客户端与Kafka生产者联系起来的处理方法,对大家解决问题具有一定的参考价值,需要的朋友们下面随着小编来一起学习吧!
问题描述
是否可以将cometD客户端与Kafka生产者连接?有什么建议吗?
Is it possible to connect cometD client with Kafka producer? Any suggestions?
当前,我在python中有一个CometD客户端,该客户端正在从Salesforce对象中实时提取数据.
Currently I am having a CometD client in python which is extracting data real time from a Salesforce object.
现在,我想将该数据推送到Kafka生产者中.有可能这样做吗?以及如何?
Now I want to push that data into Kafka producer. Is it possible to do that? And how?
推荐答案
已解决.
通过使用 https://github.com/dkmadigan/python-bayeux-client从Salesforce提取事件,我得以加入Kafka经纪人.
By using https://github.com/dkmadigan/python-bayeux-client to extract the events from Salesforce, I was able to push into the Kafka broker.
这篇关于将CometD客户端与Kafka生产者联系起来的文章就介绍到这了,希望我们推荐的答案对大家有所帮助,也希望大家多多支持!