MQTT 和 Kafka 是两项互补技术,共同构成现代大规模物联网数据架构的基石。以下是您需要同时使用它们的原因。
MQTT 是一种轻量级、高效的协议,专为连接边缘侧数百万资源受限和网络不稳定的设备而设计。它在传感器和机器的数据采集方面表现卓越。
Kafka 是一个分布式流处理平台,专为高吞吐、容错的数据管道而设计。它在处理大规模数据流并将其分发至后端企业系统方面表现卓越。
探索解耦、可扩展的架构,通过 EMQX 将数百万物联网设备连接到您的 Kafka 数据流。
实时 MQTT
发布/订阅消息
利用丰富的功能集,专为物联网与大数据平台之间关键任务、高性能数据集成而设计。
上汽大众选择 EMQX 构建新一代车联网平台。EMQX 在处理海量 MQTT 数据方面的高可靠性和可扩展性,加上其强大的 Kafka 数据桥接能力,支持了他们在实时诊断、OTA 升级和驾驶行为分析方面的需求。
100 万+ 并发连接
10 万+ 消息/秒
只需几次点击,即可使用 EMQX 强大的规则引擎和流程设计器配置数据桥接,将 MQTT 消息流式传输到 Kafka。
从智能网联汽车到智能工厂,了解 EMQX 与 Kafka 集成如何驱动数据密集型应用。
探索我们的技术资源,掌握 MQTT 与 Kafka 集成。
MQTT 到 Kafka 桥接是一个组件,它从 MQTT Broker 消费消息并将其转发到 Kafka 集群。这使得通过 MQTT 通信的物联网设备能够将其数据传输到使用 Kafka 作为高吞吐数据总线的后端系统和大数据平台进行处理。
EMQX 是一款大规模可扩展的 MQTT Broker,可处理数百万并发设备连接。其内置的数据集成引擎提供原生、高性能的 Kafka 桥接,提供数据转换、可靠传输和双向数据流等功能,无需编写复杂的自定义代码。
可以。EMQX 内置强大的基于 SQL 的规则引擎,支持实时处理数据。您可以在消息发布到 Kafka 主题之前对 MQTT 消息负载和元数据进行过滤、重新格式化、丰富和转换,确保数据符合下游消费者所需的格式。