MQTT ETL Source

MQTT Data Source reads data from MQTT queue or topic.

Configuring MQTT Data Source

To add an MQTT Data Source into your pipeline, drag the Data Source to the canvas and right-click on it to configure.

Schema Type

See the topic Provide Schema for ETL Source → to know how schema details can be provided for data sources.

After providing schema type details, the next step is to configure the data source.

Data Source Configuration

Configure the data source parameters as explained below.

Connection Name Connections are the service identifiers.

Select the connection name from the available list of connections, from where you would like to read the data.

QueueName/TopicName Queue/topic name from which messages will be read.

Add Configuration To add additional properties in key-value pairs.

Click on the Add Notes tab. Enter the notes in the space provided.

Click Done to save the configuration.

Top