MQTT 到 Logstash 配置的问题 - 未知设置错误

Question

我正在使用以下 Logstash 配置：

input {
  mqtt {
    client_id => "logstash"
    host => "127.0.0.1"
    port => 1883
    topics => ["/Application1/Message"]
    qos => 1
    id => "mqtt_input"
  }
}

output {
  stdout { codec => rubydebug }

  elasticsearch {
    hosts => ["http://localhost:9200"]
    index => "test.logstash"
    user => "elastic"
    password => "xyz"
  }
}

收到错误： 我在运行 Logstash 时收到以下错误：

[ERROR][logstash.inputs.mqtt] Unknown setting 'host' for mqtt
[ERROR][logstash.inputs.mqtt] Unknown setting 'topics' for mqtt

故障排除尝试：

我检查了Logstash文档和MQTT输入插件，但没有发现配置有任何差异。 我也尝试根据文档调整配置，但问题仍然存在。 附加信息：

Logstash版本：logstash-8.11.1-windows-x86_64

MQTT 输入插件版本：

有人可以帮助理解为什么 Logstash 会针对 MQTT 输入插件配置抛出这些未知的设置错误吗？任何建议或指导将不胜感激。

Answer 1

插件“logstash-input-mqtt”（0.0.2）不起作用！尝试安装和使用“logstash-input-paho-mqtt”