HiveMQ Logo

HiveMQ Enterprise Extension for Kafka

Category: Data Integration
Version: Bundled with HiveMQ   |   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.

star-icon 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.

Forward MQTT topics to Kafka clusters
Poll and publish information from a Kafka topic

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.

Dynamically generate values extracted from a Kafka record
Use MQTT topic filters to route MQTT messages to Kafka topics

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.

Ensure High availability and failure tolerance
Monitor all MQTT messages sent to-and-from Kafka

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.

Validate messages from Kafka
Specify custom handling of message transformations

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.


Learn how we can help you

Talk to an expert and learn how the HiveMQ platform can help you.