dom
/
telegraf
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

Expand documentation of 'qos' configuration in mqtt_consumer input (#4784)

This commit is contained in:
Rodney Gitzel 2018-10-03 17:21:30 -07:00 committed by Daniel Nelson
parent 927cac0074
commit 9efe7c12f0
3 changed files with 25 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
etc/telegraf.conf
View File

@ -3918,8 +3918,15 @@
# ## schema can be tcp, ssl, or ws. # ## schema can be tcp, ssl, or ws.
# servers = ["tcp://localhost:1883"] # servers = ["tcp://localhost:1883"]
# #
# ## MQTT QoS, must be 0, 1, or 2 # ## QoS policy for messages
# ## 0 = at most once
# ## 1 = at least once
# ## 2 = exactly once
# ##
# ## When using a QoS of 1 or 2, you should enable persistent_session to allow
# ## resuming unacknowledged messages.
# qos = 0 # qos = 0
#
# ## Connection timeout for initial connection in seconds # ## Connection timeout for initial connection in seconds
# connection_timeout = "30s" # connection_timeout = "30s"
# #

10
plugins/inputs/mqtt_consumer/README.md
View File

@ -13,8 +13,16 @@ The plugin expects messages in the
## MQTT broker URLs to be used. The format should be scheme://host:port, ## MQTT broker URLs to be used. The format should be scheme://host:port,
## schema can be tcp, ssl, or ws. ## schema can be tcp, ssl, or ws.
servers = ["tcp://localhost:1883"] servers = ["tcp://localhost:1883"]
## MQTT QoS, must be 0, 1, or 2
## QoS policy for messages
## 0 = at most once
## 1 = at least once
## 2 = exactly once
##
## When using a QoS of 1 or 2, you should enable persistent_session to allow
## resuming unacknowledged messages.
qos = 0 qos = 0
## Connection timeout for initial connection in seconds ## Connection timeout for initial connection in seconds
connection_timeout = "30s" connection_timeout = "30s"

9
plugins/inputs/mqtt_consumer/mqtt_consumer.go
View File

@ -53,8 +53,15 @@ var sampleConfig = `
## schema can be tcp, ssl, or ws. ## schema can be tcp, ssl, or ws.
servers = ["tcp://localhost:1883"] servers = ["tcp://localhost:1883"]
## MQTT QoS, must be 0, 1, or 2 ## QoS policy for messages
## 0 = at most once
## 1 = at least once
## 2 = exactly once
##
## When using a QoS of 1 or 2, you should enable persistent_session to allow
## resuming unacknowledged messages.
qos = 0 qos = 0
## Connection timeout for initial connection in seconds ## Connection timeout for initial connection in seconds
connection_timeout = "30s" connection_timeout = "30s"