|
| 1 | +# MQTT Plugin |
| 2 | + |
| 3 | +The **MQTT Plugin** extends flow records with MQTT (Message Queuing Telemetry Transport) message information. |
| 4 | + |
| 5 | +## Features |
| 6 | + |
| 7 | +- Extracts and exports MQTT fields if flow contains MQTT information. |
| 8 | +- Only MQTT v3.1.1 and v5.0 are supported. |
| 9 | +- Flow is finished when *disconect* message is received. |
| 10 | + |
| 11 | +## Parameters |
| 12 | + |
| 13 | +| Long name | Short name | Type | Default | Description | |
| 14 | +|-----------|------------|--------|---------|-------------------------------------------------------------| |
| 15 | +| `tc` | `topiccount` | `int` | 10 | Maximal count of topics from *publish* messages to save | |
| 16 | + |
| 17 | +## Output Fields |
| 18 | + |
| 19 | + MQTT_TYPE_CUMULATIVE = 0, |
| 20 | + MQTT_VERSION, |
| 21 | + MQTT_CONNECTION_FLAGS, |
| 22 | + MQTT_KEEP_ALIVE, |
| 23 | + MQTT_CONNECTION_RETURN_CODE, |
| 24 | + MQTT_PUBLISH_FLAGS, |
| 25 | + MQTT_TOPICS, |
| 26 | + |
| 27 | + |
| 28 | +| Field Name | Data Type | Description | |
| 29 | +|-----------------|-----------|----------------------------------------| |
| 30 | +| `MQQT_TYPE_CUMULATIVE`| `uint16_t` | Bitfield of messages that were detected during the communication. |
| 31 | +DISCONNECT \| PINGRESP(1b) \| PINGREQ(1b) \| UNSUBACK(1b) \| UNSUBSCRIBE(1b) /| |
| 32 | + SUBACK(1b) | SUBSCRIBE(1b) | PUBCOMP(1b) | PUBREL(1b) | PUBREC(1b) | PUBACK(1b) | PUBLISH(1b) | |
| 33 | + CONNACK(1b) | CONNECT(1b) | session present(1b) | |
| 34 | +| `MQTT_VERSION`| `uint8_t` | | |
| 35 | +| `MQTT_CONNECTION_FLAGS`| `uint8_t` | | |
| 36 | +| `MQTT_KEEP_ALIVE`| `uint8_t` | | |
| 37 | +| `MQTT_VERSION`| `uint8_t` | | |
| 38 | + |
| 39 | +## Usage |
| 40 | + |
| 41 | +### YAML Configuration |
| 42 | + |
| 43 | +Add the plugin to your ipfixprobe YAML configuration: |
| 44 | + |
| 45 | +```yaml |
| 46 | +process_plugins: |
| 47 | + - dnssd |
| 48 | +``` |
| 49 | +
|
| 50 | +### CLI Usage |
| 51 | +
|
| 52 | +You can also enable the plugin directly from the command line: |
| 53 | +
|
| 54 | +```ipfixprobe -p dnssd ...``` |
| 55 | +```ipfixprobe -p "dnssd;txt" ...``` |
| 56 | +```ipfixprobe -p "dnssd;txt=<path_to_file>" ...``` |
0 commit comments