【发布时间】:2018-06-06 10:24:44
【问题描述】:
是否可以将 cometD 客户端与 Kafka 生产者连接起来?有什么建议吗?
目前我在 python 中有一个 CometD 客户端,它从 Salesforce 对象中实时提取数据。
现在我想将这些数据推送到 Kafka 生产者中。有可能这样做吗?怎么做?
【问题讨论】:
标签: apache-kafka kafka-consumer-api kafka-producer-api cometd
是否可以将 cometD 客户端与 Kafka 生产者连接起来?有什么建议吗?
目前我在 python 中有一个 CometD 客户端,它从 Salesforce 对象中实时提取数据。
现在我想将这些数据推送到 Kafka 生产者中。有可能这样做吗?怎么做?
【问题讨论】:
标签: apache-kafka kafka-consumer-api kafka-producer-api cometd
解决了。
通过使用https://github.com/dkmadigan/python-bayeux-client 从 Salesforce 中提取事件,我能够推送到 Kafka 代理。
【讨论】: