Purpose: Integration
Bundled with:
Version 4.1 and above
| License: Commercial
Provider: HiveMQ | Verified: yes
Product Resources Please use the following links to download and try the extension, read the installation guide, learn more about features, or find out how we can help.
About this Extension
This extension adds monitored, bi-directional MQTT messaging to and from your Kafka installation. It implements the native Kafka protocol, so HiveMQ acts as a first-class Kafka client. This allows MQTT topics to be mapped directly to Kafka topics and forward messages directly to multiple Kafka clusters (and vice versa) in a high-performant, scalable and reliable manner.
Buy License
Features
Connect and route IoT device data to multiple Kafka clusters allowing for a single HiveMQ platform to support different types of devices and routing device data to different back-end applications.
Support of all MQTT 3.1.1 and MQTT 5 features.
Poll information from a Kafka topic and publish this information as MQTT messages to one or more MQTT topics.
Use multiple MQTT topic filters with full support of MQTT wildcards to route MQTT messages to the desired Kafka topic.
End-to-end persistent messaging guarantees from device to Kafka so no messages are lost.
Track all MQTT messages to and from Kafka on a centralized HiveMQ control center.
New features with the 4.12 release:
Added tracing support in the extension for MqttToKafkaTransformer customizations; that can create multiple Kafka records from a single MQTT message.
Export information about the extension in a diagnostic archive to further facilitate support and troubleshooting.
How to install
This extension is preinstalled in your download of the HiveMQ platform and disabled. To enable the HiveMQ Enterprise Extension for Kafka, locate the folder of the extension in your HiveMQ installation and remove the DISABLED file.
The extension is now installed and needs to be configured for your individual Kafka cluster(s) and topics. An example configuration file can be found inside the unzipped folder. See the configuration chapter in the official documentation for all possible configuration options.
You can verify that the extension is installed and configured properly by checking your HiveMQ log files and the created Kafka tab of the HiveMQ Control Center.
Download the latest version of the HiveMQ platform, which contains an evaluation version of this extension. The evaluation version is limited to a 5-hour operating window. You can reset this window by restarting the HiveMQ broker each time. For the production version of this extension, please contact our sales team.