Skip to content

Commit d6b6fa5

Browse files
Merge pull request #296312 from PatAltimore/patricka-dataflow-connectivity
Add local MQTT broker subscriber queue detail
2 parents 3e2f403 + 3631d60 commit d6b6fa5

File tree

1 file changed

+8
-2
lines changed

1 file changed

+8
-2
lines changed

articles/iot-operations/connect-to-cloud/overview-dataflow.md

Lines changed: 8 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -6,7 +6,7 @@ ms.author: patricka
66
ms.service: azure-iot-operations
77
ms.subservice: azure-data-flows
88
ms.topic: conceptual
9-
ms.date: 11/11/2024
9+
ms.date: 03/17/2025
1010

1111
#CustomerIntent: As an operator, I want to understand how I can use data flows to connect data sources.
1212
---
@@ -62,10 +62,16 @@ By using data flows, you can efficiently manage your data paths. You can ensure
6262

6363
Schema registry, a feature provided by Azure Device Registry, is a synchronized repository in the cloud and at the edge. The schema registry stores the definitions of messages coming from edge assets, and then exposes an API to access those schemas at the edge. Southbound connectors like the connector for OPC UA can create message schemas and add them to the schema registry or customers can upload schemas to the operations experience web UI.
6464

65-
Data flows uses messages schemas to transform the message into the format expected by the destination endpoint.
65+
Data flows use message schemas to transform the message into the format expected by the destination endpoint.
6666

6767
For more information, see [Understand message schemas](./concept-schema-registry.md).
6868

69+
## Local MQTT broker endpoint message storage
70+
71+
When you use the local MQTT broker as a source endpoint in a data flow, messages are stored during a loss of connectivity between the data flow and the destination endpoint. As an example scenario, assume you create a data flow using the default local MQTT broker as the source endpoint and Azure Event Hubs as the destination endpoint. If connectivity between the data flow and Azure Event Hubs is lost, messages are stored in the MQTT broker subscriber message queue. When connectivity is restored, the data flow sends the messages in the subscriber message queue to Azure Event Hubs.
72+
73+
The local MQTT broker message queue is stored in memory by default. You can configure the MQTT broker to store messages on disk by using the disk-backed message buffer configuration. For more information about the MQTT broker configuration, see [Configure broker settings for high availability, scaling, and memory usage](../manage-mqtt-broker/howto-configure-availability-scale.md). For more information about the disk-backed message buffer, see [Configure disk-backed message buffer behavior](../manage-mqtt-broker/howto-disk-backed-message-buffer.md).
74+
6975
## Related content
7076

7177
- [Tutorial: Send asset telemetry to the cloud by using a data flow](../end-to-end-tutorials/tutorial-upload-telemetry-to-cloud.md)

0 commit comments

Comments
 (0)