时间戳

首页 > 解决方案 > Confluent Kafka Connect MQTT Source 和 Sink 连接器的开源替代方案

apache-kafka - Confluent Kafka Connect MQTT Source 和 Sink 连接器的开源替代方案

问题描述

我想通过 MQTT 代理连接到 Apache Kafka（非企业版，不使用融合的 kafka 托管服务）。

我使用的是 Confluent 的 Kafka Connect MQTT 源和接收器，但我意识到它带有 30 天的试用期，之后需要许可证。

是否有任何其他开源/免费选项可用作 Apache Kafka 和 mqtt 代理之间的双向桥梁。

标签： apache-kafkamqttapache-kafka-connectconfluent-platform

解决方案

您可以使用Lenses 的 MQTT 源连接器：

一个连接器，用于从 MQTT 读取事件并将它们推送到 Kafka。连接器订阅指定的主题并将记录流式传输到 Kafka。

Lenses 还提供MQTT Sink 连接器，用于将记录从 Kafka 流式传输到目标系统。

两个连接器都需要以下内容：

  • Apache Kafka 0.11.x 以上
  • Kafka Connect 2.x 或更高版本
  • MQTT 服务器
  • Java 1.8

推荐阅读