如何在Telegraf MQTT监听器中指定clean=false参数？

核心问题解答 #

Telegraf的MQTT输入插件并未直接提供clean参数，但它的persistent_session配置项与MQTT的clean参数一一对应：

• 当设置persistent_session = true时，等价于MQTT协议中的clean=false，Broker会保留会话状态、订阅关系以及未投递的消息，直到客户端重新连接或达到消息过期/会话超时限制。
• 当设置persistent_session = false时，等价于clean=true，客户端断开连接后，Broker会立即清理相关会话和未投递消息。

MQTT区分离线与进程终止的机制 #

MQTT协议通过心跳保活（keepalive）机制判断客户端状态：

• 客户端会按约定的keepalive间隔发送心跳包，告知Broker自身在线状态。
• 若Telegraf进程意外终止，客户端无法主动发送DISCONNECT报文，Broker会在超过keepalive时间后判定客户端离线。
• 对于clean=false（即Telegraf中persistent_session=true）的会话，Broker会保留该客户端的订阅和未投递消息，直到触发以下任一条件：
  1. 客户端使用相同Client ID重新连接；
  2. 消息达到预设的过期时间；
  3. 会话达到Broker配置的超时阈值（比如ActiveMQ Artemis可自定义会话超时规则）。

补充说明 #

意外终止Telegraf进程后，消息不会被永久保留，Broker会根据自身的消息过期策略和会话超时配置自动清理无效消息，这与你提到的“可接受”预期一致。

内容的提问来源于stack exchange，提问作者Jack BeNimble