本文介绍了将 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 生产者连接起来的文章就介绍到这了,希望我们推荐的答案对大家有所帮助,也希望大家多多支持!