Add MQTT source to an eventstream (preview)

This article shows you how to add a Message Queuing Telemetry Transport (MQTT) source to an eventstream in Fabric Real-Time Intelligence.

Message Queuing Telemetry Transport (MQTT) is a lightweight publish-subscribe messaging protocol designed for constrained environments and widely used for Internet of Things (IoT) scenarios. The MQTT Connector for Fabric Eventstream allows you to connect to any MQTT broker and ingest messages directly into Eventstream, enabling real-time transformation and routing to various destinations within Fabric for analytics and insights.

Prerequisites

Before you start, you must complete the following prerequisites:

• A workspace with Fabric capacity or Fabric Trial workspace type.
• Access to the workspace with Contributor or higher workspace roles.
• Ensure that the MQTT broker is publicly accessible and not restricted by a firewall or a virtual network. If it resides in a protected network, connect to it by using Eventstream connector virtual network injection.

Depending on your scenario, you can also use one of the following approaches to stream MQTT data to Eventstream:

• Azure Event Grid: Send MQTT data to Azure Event Grid and set up an Azure Event Grid connector in Eventstream. For more information, see Add Azure Event Grid Namespace as a source to an eventstream.
• Azure IoT Operations: Configure a data flow endpoint that connects to an Eventstream Custom Endpoint. For more information, see Configure data flow endpoints for Microsoft Fabric Real-Time Intelligence.

Add MQTT connector

You can add the MQTT connector to Eventstream in two ways:

From an eventstream

Add an MQTT source directly to an eventstream. This approach works best when you want to set up a dedicated eventstream for processing and routing MQTT data.

1. In Fabric Real-Time Intelligence, create a new Eventstream or open an existing one.

2. Select Add source on the canvas.

   

From Real-Time hub

Connect to an MQTT source from Real-Time hub and create a data stream. This approach works best when you want to discover and manage your MQTT data stream alongside other streaming sources.

1. In Fabric, go to Real-Time hub.

2. Select Add data and search for MQTT.

   

Configure MQTT connector

1. On the Connect page, select New connection.

   

   If there's an existing connection to your MQTT source, select that existing connection.

2. To create a new cloud connection, enter the following information:

   

   1. MQTT Broker URL: enter the URL of your MQTT broker. The supported protocols are ssl://, wss://, and tcp://.

      Note

      The MQTT source supports Transport Layer Security (TLS) or Secure Sockets Layer (SSL) secured MQTT connections between your MQTT broker and Eventstream. TLS or SSL connections are only supported if the server certificate is signed by a Certificate Authority (CA) included in the trusted CA list.

   2. Connection name: enter a name for the connection to the MQTT.

   3. Enter the Username and Password of your MQTT broker.

   4. Select Connect.

3. For Topic name, enter the MQTT topic to subscribe to. The connector supports only a single topic.

4. For Version, select either V5 or V3 based on your MQTT broker's protocol version.

Stream or source details

1. On the Connect page, follow one of these steps based on whether you're using Eventstream or Real-Time hub.

   • Eventstream:

     In the Source details pane to the right, follow these steps:

     1. For Source name, select the Pencil button to change the name.

     2. Notice that Eventstream name and Stream name are read-only.

   • Real-Time hub:

     In the Stream details section to the right, follow these steps:

     1. Select the Fabric workspace where you want to create the eventstream.

     2. For Eventstream name, select the Pencil button, and enter a name for the eventstream.

     3. The Stream name value is automatically generated for you by appending -stream to the name of the eventstream. This stream appears on the real-time hub's All data streams page when the wizard finishes.

2. Select Next at the bottom of the Configure page.

Review and connect

On the Review + connect screen, review the summary, and select Add (Eventstream) or Connect (Real-Time hub).

View updated eventstream

1. The MQTT source appears on your eventstream canvas in Edit mode. To publish, select Publish on the ribbon.

   

2. After you publish, the source is available in Live view. Select the MQTT tile in the diagram to view details.

   

Related content

For a list of all supported sources, see Add and manage an event source.