Kafka Plugin


Kafka plugin is responsible for sending messages to Kafka brokers triggered by specific rules


You can specify following configuration parameters:

Server-side API

This plugin does not provide any server-side API.


In this example, we are going to demonstrate how you can configure this extension to be able to send a message to Kafka topic every time new telemetry message for the device arrives.

Prerequisites before contining Kafka extension configuration:

Kafka Plugin Configuration

Let’s configure Kafka plugin first. Go to Plugins menu and create new plugin:



Please set correctly Kafka Bootstrap Servers URL and any other parameters located in plugin configuration section that is suitable for your case so Kafka extension is able to connect to Kafka broker.

Click on ‘Activate’ plugin button:


Kafka Rule Configuration

Now it’s time to create appropriate Rule.


Add filter for POST_TELEMETRY message type:


Click ‘Add’ button to add filter.

Then select ‘Kafka Plugin’ in the drop-down box for the Plugin field:


Add action that will send temperature telemetry of device to particular kafka topic:


Click ‘Add’ button and then activate Rule.

Sending Temperature Telemetry

Now you can send Telemetry message that contains ‘temp’ telemetry for any of your devices:


You should see ‘73.4’ message in appropriate Kafka topic once you’ll post this message.

Here is an example of a command that publish single telemetry message to locally installed ThingsBoard:

mosquitto_pub -d -h "localhost" -p 1883 -t "v1/devices/me/telemetry" -u "$ACCESS_TOKEN" -m '{"temp":73.4}'