如何将MQTT代理连接到本地kafka源

Question

基本上我想从MQTT(蚊子)代理发送消息到本地事件源(kafka)。在一个简单的kafka代理的情况下，我可以使用confluent的kafkaconnect，但在这种情况下，它是一个已知的事件源而不是代理。问题在于向云事件的转换。

Answer 1

既然你有一个当前的MQTT代理可以读写Kafka，你可以使用Kafka源将Kafka消息转换为CloudEvents并将它们发送到你的服务。

如果你在问如何将MQTT代理与Kafka连接，我建议要么找到或编写MQTT源，要么使用Knative生态系统之外的东西。