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: pipeline/inputs/mqtt.md
+22-15Lines changed: 22 additions & 15 deletions
Display the source diff
Display the rich diff
Original file line number
Diff line number
Diff line change
@@ -1,28 +1,35 @@
1
1
# MQTT
2
2
3
-
The **MQTT** input plugin, allows to retrieve messages/data from MQTT control packets over a TCP connection. The incoming data to receive _must_ be a JSON map.
3
+
The _MQTT_ input plugin retrieves messages and data from MQTT control packets over a TCP connection. The incoming data to receive must be a JSON map.
4
4
5
-
## Configuration Parameters
5
+
## Configuration parameters
6
6
7
7
The plugin supports the following configuration parameters:
|`Port`| TCP port where listening for connections. |`1883`|
13
+
|`Payload_Key`| Specify the key where the payload key/value will be preserved. |_none_|
14
+
|`Threaded`| Indicates whether to run this input in its own [thread](../../administration/multithreading.md#inputs). |`false`|
15
15
16
-
## Getting Started
16
+
## Get started
17
17
18
-
In order to start listening for MQTT messages, you can run the plugin from the command line or through the configuration file:
18
+
To listen for MQTT messages, you can run the plugin from the command line or through the configuration file.
19
19
20
-
### Command Line
20
+
### Command line
21
21
22
-
Since the **MQTT** input plugin let Fluent Bit behave as a server, we need to dispatch some messages using some MQTT client, in the following example _mosquitto_ tool is being used for the purpose:
22
+
The MQTT input plugin lets Fluent Bit behave as a server. Dispatch some messages using a MQTT client. In the following example, the `mosquitto` tool is being used for the purpose:
0 commit comments