apache-kafka - 将 CometD 客户端与 Kafka 生产者连接

Question

是否可以将 cometD 客户端与 Kafka 生产者连接起来？有什么建议么？

目前我在 python 中有一个 CometD 客户端，它从 Salesforce 对象中实时提取数据。

现在我想将这些数据推送到 Kafka 生产者中。有可能这样做吗？如何？

标签： apache-kafkakafka-consumer-apikafka-producer-apicometd

Answer 1

解决了。

通过使用https://github.com/dkmadigan/python-bayeux-client从 Salesforce 中提取事件，我能够推送到 Kafka 代理。