Logstash 无法连接到我的 RabbitMQ Broker

问题描述

我正在尝试将在 docker 容器中运行的 Logstash 实例连接到 Amazon MQ 代理。 我的最终目标是将 MQ 消息体插入 ElasticSearch

根据日志，我认为 Logstash 能够访问 MQ 队列，但错误消息没有提供任何其他信息：

[2021-05-21T23:30:53,226][ERROR][logstash.inputs.rabbitmq ][instance_journal_pipeline][rmq_instance_source] 
RabbitMQ connection error,will retry. {
  :error_message=>"An unkNown error occurred. RabbitMQ gave no hints as to the cause. Maybe this is a configuration error (invalid vhost,for example). I recommend checking the RabbitMQ server logs for clues about this failure.",:exception=>"Java::JavaIo::IOException"
}

我的输入配置如下：

input {
   rabbitmq {
     id => "rmq_instance_source"
     ack => true
     durable => true
     passive => true
     exchange => "events"
     exchange_type => "topic"
     host => "${AWS_MQ_URL}"
     user => "${AWS_MQ_USER}"
     port => "${AWS_MQ_PORT}"
     password => "${AWS_MQ_PASSWORD}"
     queue => "outbound_task_queue_name"
     key => "outbound_task_key"
     arguments => {
       # arguments reproduced from the RMQ Queue's admin page
     }
  }
}

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）