连接 CometD 客户端和 Kafka 生产者

Question

是否可以连接cometD客户端和Kafka生产者？有什么建议吗？

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

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

Answer 1

已解决。

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