You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
Copy file name to clipboardExpand all lines: articles/iot-operations/connect-to-cloud/howto-configure-kafka-endpoint.md
+2-2Lines changed: 2 additions & 2 deletions
Display the source diff
Display the rich diff
Original file line number
Diff line number
Diff line change
@@ -6,7 +6,7 @@ ms.author: patricka
6
6
ms.service: azure-iot-operations
7
7
ms.subservice: azure-data-flows
8
8
ms.topic: how-to
9
-
ms.date: 04/03/2025
9
+
ms.date: 05/21/2025
10
10
ai-usage: ai-assisted
11
11
12
12
#CustomerIntent: As an operator, I want to understand how to configure data flow endpoints for Kafka in Azure IoT Operations so that I can send data to and from Kafka endpoints.
@@ -1027,7 +1027,7 @@ CloudEvent properties are passed through for messages that contain the required
1027
1027
| `type` | Yes | `ms.aio.telemetry` | `ce-type` | Passed through as is |
1028
1028
| `source` | Yes | `aio://mycluster/myoven` | `ce-source` | Passed through as is |
1029
1029
| `id` | Yes | `A234-1234-1234` | `ce-id` | Passed through as is |
1030
-
| `subject` | No | `aio/myoven/telemetry/temperature` | `ce-subject` | Passed through as is |
1030
+
| `subject` | No | `aio/myoven/sensor/temperature` | `ce-subject` | Passed through as is |
1031
1031
| `time` | No | `2018-04-05T17:31:00Z` | `ce-time` | Passed through as is. It's not restamped. |
1032
1032
| `datacontenttype` | No | `application/json` | `ce-datacontenttype` | Changed to the output data content type after the optional transform stage. |
1033
1033
| `dataschema` | No | `sr://fabrikam-schemas/123123123234234234234234#1.0.0` | `ce-dataschema` | If an output data transformation schema is given in the transformation configuration, `dataschema` is changed to the output schema. |
Copy file name to clipboardExpand all lines: articles/iot-operations/connect-to-cloud/howto-configure-mqtt-endpoint.md
+2-2Lines changed: 2 additions & 2 deletions
Display the source diff
Display the rich diff
Original file line number
Diff line number
Diff line change
@@ -6,7 +6,7 @@ ms.author: patricka
6
6
ms.service: azure-iot-operations
7
7
ms.subservice: azure-data-flows
8
8
ms.topic: how-to
9
-
ms.date: 04/03/2025
9
+
ms.date: 05/21/2025
10
10
ai-usage: ai-assisted
11
11
12
12
#CustomerIntent: As an operator, I want to understand how to understand how to configure data flow endpoints for MQTT sources and destinations in Azure IoT Operations so that I can send data to and from MQTT brokers.
@@ -1017,7 +1017,7 @@ CloudEvent properties are passed through for messages that contain the required
1017
1017
| `type` | Yes | `ms.aio.telemetry` | Passed through as is |
1018
1018
| `source` | Yes | `aio://mycluster/myoven` | Passed through as is |
1019
1019
| `id` | Yes | `A234-1234-1234` | Passed through as is |
1020
-
| `subject` | No | `aio/myoven/telemetry/temperature` | Passed through as is |
1020
+
| `subject` | No | `aio/myoven/sensor/temperature` | Passed through as is |
1021
1021
| `time` | No | `2018-04-05T17:31:00Z` | Passed through as is. It's not restamped. |
1022
1022
| `datacontenttype` | No | `application/json` | Changed to the output data content type after the optional transform stage. |
1023
1023
| `dataschema` | No | `sr://fabrikam-schemas/123123123234234234234234#1.0.0` | If an output data transformation schema is given in the transformation configuration, `dataschema` is changed to the output schema. |
Copy file name to clipboardExpand all lines: articles/iot-operations/connect-to-cloud/howto-create-dataflow.md
+11-11Lines changed: 11 additions & 11 deletions
Display the source diff
Display the rich diff
Original file line number
Diff line number
Diff line change
@@ -209,8 +209,8 @@ The message broker endpoint is configured in the Bicep file. For example, the fo
209
209
sourceSettings: {
210
210
endpointRef: 'default'
211
211
dataSources: [
212
-
'thermostats/+/telemetry/temperature/#'
213
-
'humidifiers/+/telemetry/humidity/#'
212
+
'thermostats/+/sensor/temperature/#'
213
+
'humidifiers/+/sensor/humidity/#'
214
214
]
215
215
}
216
216
```
@@ -225,8 +225,8 @@ For example, to configure a source using a message broker endpoint and two topic
225
225
sourceSettings:
226
226
endpointRef: default
227
227
dataSources:
228
-
- thermostats/+/telemetry/temperature/#
229
-
- humidifiers/+/telemetry/humidity/#
228
+
- thermostats/+/sensor/temperature/#
229
+
- humidifiers/+/sensor/humidity/#
230
230
```
231
231
232
232
Because `dataSources` allows you to specify MQTT or Kafka topics without modifying the endpoint configuration, you can reuse the endpoint for multiple data flows even if the topics are different. To learn more, see [Configure data sources](#configure-data-sources-mqtt-or-kafka-topics).
@@ -319,7 +319,7 @@ You can specify multiple MQTT or Kafka topics in a source without needing to mod
319
319
320
320
#### MQTT topics
321
321
322
-
When the source is an MQTT (Event Grid included) endpoint, you can use the MQTT topic filter to subscribe to incoming messages. The topic filter can include wildcards to subscribe to multiple topics. For example, `thermostats/+/telemetry/temperature/#` subscribes to all temperature telemetry messages from thermostats. To configure the MQTT topic filters:
322
+
When the source is an MQTT (Event Grid included) endpoint, you can use the MQTT topic filter to subscribe to incoming messages. The topic filter can include wildcards to subscribe to multiple topics. For example, `thermostats/+/sensor/temperature/#` subscribes to all temperature sensor messages from thermostats. To configure the MQTT topic filters:
323
323
324
324
# [Operations experience](#tab/portal)
325
325
@@ -344,13 +344,13 @@ Example with multiple MQTT topic filters with wildcards:
344
344
sourceSettings: {
345
345
endpointRef: 'default'
346
346
dataSources: [
347
-
'thermostats/+/telemetry/temperature/#'
348
-
'humidifiers/+/telemetry/humidity/#'
347
+
'thermostats/+/sensor/temperature/#'
348
+
'humidifiers/+/sensor/humidity/#'
349
349
]
350
350
}
351
351
```
352
352
353
-
Here, the wildcard `+` is used to select all devices under the `thermostats` and `humidifiers` topics. The `#` wildcard is used to select all telemetry messages under all subtopics of the `temperature` and `humidity` topics.
353
+
Here, the wildcard `+` is used to select all devices under the `thermostats` and `humidifiers` topics. The `#` wildcard is used to select all sensor messages under all subtopics of the `temperature` and `humidity` topics.
354
354
355
355
# [Kubernetes (preview)](#tab/kubernetes)
356
356
@@ -369,11 +369,11 @@ Example with multiple topic filters with wildcards:
369
369
sourceSettings:
370
370
endpointRef: default
371
371
dataSources:
372
-
- thermostats/+/telemetry/temperature/#
373
-
- humidifiers/+/telemetry/humidity/#
372
+
- thermostats/+/sensor/temperature/#
373
+
- humidifiers/+/sensor/humidity/#
374
374
```
375
375
376
-
Here, the wildcard `+` is used to select all devices under the `thermostats` and `humidifiers` topics. The `#` wildcard is used to select all telemetry messages under all subtopics of the `temperature` and `humidity` topics.
376
+
Here, the wildcard `+` is used to select all devices under the `thermostats` and `humidifiers` topics. The `#` wildcard is used to select all messages under all subtopics of the `temperature` and `humidity` topics.
Copy file name to clipboardExpand all lines: articles/iot-operations/connect-to-cloud/tutorial-mqtt-bridge.md
+13-13Lines changed: 13 additions & 13 deletions
Display the source diff
Display the rich diff
Original file line number
Diff line number
Diff line change
@@ -6,7 +6,7 @@ ms.author: patricka
6
6
ms.service: azure-iot-operations
7
7
ms.subservice: azure-data-flows
8
8
ms.topic: tutorial
9
-
ms.date: 01/08/2025
9
+
ms.date: 05/21/2025
10
10
11
11
#CustomerIntent: As an operator, I want to understand how to create a bi-directional MQTT bridge to Azure Event Grid so that I can send and receive messages between devices and services.
12
12
---
@@ -115,7 +115,7 @@ The max client sessions option allows Azure IoT Operations MQTT to spawn multipl
115
115
116
116
## Create a topic space
117
117
118
-
In the Event Grid namespace, create a topic space named `tutorial` with a topic template `telemetry/#`.
118
+
In the Event Grid namespace, create a topic space named `tutorial` with a topic template `sensor/#`.
119
119
120
120
# [Bash](#tab/bash)
121
121
@@ -124,7 +124,7 @@ az eventgrid namespace topic-space create \
124
124
--resource-group $RESOURCE_GROUP \
125
125
--namespace-name $EVENT_GRID_NAMESPACE \
126
126
--name tutorial \
127
-
--topic-templates "telemetry/#"
127
+
--topic-templates "sensor/#"
128
128
```
129
129
130
130
# [PowerShell](#tab/powershell)
@@ -134,12 +134,12 @@ az eventgrid namespace topic-space create `
134
134
--resource-group $RESOURCE_GROUP `
135
135
--namespace-name $EVENT_GRID_NAMESPACE `
136
136
--name tutorial `
137
-
--topic-templates "telemetry/#"
137
+
--topic-templates "sensor/#"
138
138
```
139
139
140
140
---
141
141
142
-
By using the `#` wildcard in the topic template, you can publish to any topic under the `telemetry` topic space. For example, `telemetry/temperature` or `telemetry/humidity`.
142
+
By using the `#` wildcard in the topic template, you can publish to any topic under the `sensor` topic space. For example, `sensor/temperature` or `sensor/humidity`.
143
143
144
144
## Give Azure IoT Operations access to the Event Grid topic space
@@ -502,13 +502,13 @@ Together, the two data flows form an MQTT bridge, where you:
502
502
* Use TLS for both remote and local brokers
503
503
* Use system-assigned managed identity for authentication to the remote broker
504
504
* Use Kubernetes service account for authentication to the local broker
505
-
* Use the topic map to map the `tutorial/local` topic to the `telemetry/aio` topic on the remote broker
506
-
* Use the topic map to map the `telemetry/#` topic on the remote broker to the `tutorial/cloud` topic on the local broker
505
+
* Use the topic map to map the `tutorial/local` topic to the `sensor/aio` topic on the remote broker
506
+
* Use the topic map to map the `sensor/#` topic on the remote broker to the `tutorial/cloud` topic on the local broker
507
507
508
508
> [!NOTE]
509
509
> By default, Azure IoT Operations deploys an MQTT broker as well as an MQTT broker data flow endpoint. The MQTT broker data flow endpoint is used to connect to the MQTT broker. The default configuration uses the built-in service account token for authentication. The endpoint is named `default` and is available in the same namespace as Azure IoT Operations. The endpoint is used as the source for the data flow created in this tutorial. To learn more about the default MQTT broker data flow endpoint, see [Azure IoT Operations local MQTT broker default endpoint](../connect-to-cloud/howto-configure-mqtt-endpoint.md#default-endpoint).
510
510
511
-
When you publish to the `tutorial/local` topic on the local Azure IoT Operations MQTT broker, the message is bridged to the `telemetry/aio` topic on the remote Event Grid MQTT broker. Then, the message is bridged back to the `tutorial/cloud` topic (because the `telemetry/#` wildcard topic captures it) on the local Azure IoT Operations MQTT broker. Similarly, when you publish to the `telemetry/aio` topic on the remote Event Grid MQTT broker, the message is bridged to the `tutorial/cloud` topic on the local Azure IoT Operations MQTT broker.
511
+
When you publish to the `tutorial/local` topic on the local Azure IoT Operations MQTT broker, the message is bridged to the `sensor/aio` topic on the remote Event Grid MQTT broker. Then, the message is bridged back to the `tutorial/cloud` topic (because the `sensor/#` wildcard topic captures it) on the local Azure IoT Operations MQTT broker. Similarly, when you publish to the `sensor/aio` topic on the remote Event Grid MQTT broker, the message is bridged to the `tutorial/cloud` topic on the local Azure IoT Operations MQTT broker.
512
512
513
513
## Deploy MQTT client
514
514
@@ -621,7 +621,7 @@ You can also check the Event Grid metrics to verify the messages are delivered t
621
621
622
622
In this tutorial, you learned how to configure Azure IoT Operations for bi-directional MQTT bridge with Azure Event Grid MQTT broker. As next steps, explore the following scenarios:
623
623
624
-
* To use an MQTT client to publish messages directly to the Event Grid MQTT broker, see [Publish MQTT messages to Event Grid MQTT broker](../../event-grid/mqtt-publish-and-subscribe-cli.md). Give the client a [publisher permission binding](../../event-grid/mqtt-access-control.md) to the topic space you created, and you can publish messages to any topic under the `telemetry`, like `telemetry/temperature` or `telemetry/humidity`. All of these messages are bridged to the `tutorial/cloud` topic on the local Azure IoT Operations broker.
624
+
* To use an MQTT client to publish messages directly to the Event Grid MQTT broker, see [Publish MQTT messages to Event Grid MQTT broker](../../event-grid/mqtt-publish-and-subscribe-cli.md). Give the client a [publisher permission binding](../../event-grid/mqtt-access-control.md) to the topic space you created, and you can publish messages to any topic under the `sensor`, like `sensor/temperature` or `sensor/humidity`. All of these messages are bridged to the `tutorial/cloud` topic on the local Azure IoT Operations broker.
625
625
* To set up routing rules for the Event Grid MQTT broker, see [Configure routing rules for Event Grid MQTT broker](../../event-grid/mqtt-routing.md). You can use routing rules to route messages to different topics based on the topic name, or to filter messages based on the message content.
Copy file name to clipboardExpand all lines: articles/iot-operations/manage-mqtt-broker/howto-broker-diagnostics.md
+1-1Lines changed: 1 addition & 1 deletion
Display the source diff
Display the rich diff
Original file line number
Diff line number
Diff line change
@@ -42,7 +42,7 @@ The diagnostics probe regularly runs MQTT operations (PING, CONNECT, PUBLISH, SU
42
42
> [!IMPORTANT]
43
43
> The self-check diagnostics probe publishes messages to the `azedge/dmqtt/selftest` topic. Don't publish or subscribe to diagnostic probe topics that start with `azedge/dmqtt/selftest`. Publishing or subscribing to these topics can affect the probe or self-test checks and result in invalid results. Invalid results can be listed in diagnostic probe logs, metrics, or dashboards. For example, you might see the issue "Path verification failed for probe event with operation type 'Publish'" in the diagnostics-probe logs. For more information, see [Known issues](../troubleshoot/known-issues.md#mqtt-broker-issues).
44
44
>
45
-
> Even though the MQTT broker's [diagnostics](../manage-mqtt-broker/howto-broker-diagnostics.md) produces telemetry on its own topic, you can still get messages from the self-test when you subscribe to the `#` topic. This is a limitation and expected behavior.
45
+
> Even though the MQTT broker's [diagnostics](../manage-mqtt-broker/howto-broker-diagnostics.md) produces diagnostics messages on its own topic, you can still get messages from the self-test when you subscribe to the `#` topic. This is a limitation and expected behavior.
0 commit comments