HiveMQ Enterprise Extension for Kafka
Update
With the 4.17 release, the Enterprise Extension for Kafka now has the following additional features: Added tracing support in the HiveMQ Enterprise Extension for Kafka for MqttToKafkaTransformer customizations that create multiple Kafka records from a single MQTT message.
Added the capability to export information about the HiveMQ Enterprise Extension for Kafka in a diagnostic archive to facilitate support and further troubleshooting.
Here’s what you can do with this extension:
Forward MQTT messages to topics in one or more Kafka clusters
Easily forward MQTT messages to one or more Kafka clusters that are connected to your HiveMQ MQTT broker.
Poll information from a Kafka topic and publish it
Forward polling information as MQTT messages to one or more MQTT topics.
Dynamically generate MQTT messages at runtime
Use placeholders to dynamically generate values extracted from a Kafka record.
Use multiple MQTT topic filters to route MQTT messages to relevant Kafka topics.
Utilize multiple MQTT topic filters with the full support of wildcards to route MQTT messages to the desired Kafka topics.
Ensure high availability and failure tolerance
The message buffering feature on the HiveMQ MQTT broker ensures high availability and failure tolerance whenever a Kafka cluster becomes temporarily unavailable.
Monitor all MQTT messages written to and from Kafka
Use the HiveMQ control center to monitor all MQTT messages that are sent to and from Kafka.
Validate messages from Kafka
Use the schema registry to validate messages that are received from Kafka.
Specify custom handling of message transformations between HiveMQ and Kafka
Use the customization SDK to programmatically specify custom handling of message transformations between HiveMQ and Kafka.
Try HiveMQ Enterprise Extension for Kafka
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.
