MQTT to Kafka connector

Accelerate your MQTT to Kafka streaming with a Kafka compatible connector via Lenses UI/ CLI, Native plugin or Helm charts for Kubernetes deployments

MQTT to Kafka

About the MQTT to Kafka sink

License Apache 2.0

A Connector to read data from MQTT to Kafka. The connector subscribes to the specified topics and streams the records to Kafka. This is an open-source project and so isn't available with Lenses support SLAs.

Connector options for MQTT to Kafka streaming

Docker to test the connector

Test in our pre-configured Lenses & Kafka sandbox packed with connectors

Use Lenses with your Kafka

Manage the connector in Lenses against your Kafka and data.

Or MQTT to Kafka GitHub Connector

Download the connector the usual way from GitHub

Connector benefits

  • Flexible Deployment
  • Powerful Integration Syntax
  • Monitoring & Alerting
  • Integrate with your GitOps

Why use to write data from MQTT to Kafka?

This connector saves you from learning terminal commands and endless back-and-forths connecting MQTT to Kafka by managing the MQTT stream reactor connector (and all your other connectors on your Kafka Connect Cluster) through This lets you freely monitor, process and deploy data with the following features:

  • Error handling
  • Fine-grained permissions
  • Data observability
MQTT to Apache Kafka

How to set up your MQTT to Kafka data pipeline

Make sure you have:

  • Apache Kafka 0.11.x of above
  • Kafka Connect 0.11.x or above
  • MQTT server
  • Java 1.8


  1. Pluggable converters for MQTT payloads
  2. Out of the box converters for JSON/AVRO and Binary
  3. The KCQL routing querying - Topic to Topic mapping and Field selection
  4. Wildcard MQTT topic subscriptions
  5. Supports multi server MQTT connection

Share this connector

Experience all features in a single instance always free for developers

Pull docker free