logstash-plugins / logstash-input-rabbitmq

Apache License 2.0
30 stars 43 forks source link

rabbitmq connect refuse #127

Open caicai683 opened 2 years ago

caicai683 commented 2 years ago

Please include the following information:

  1. Logstash 7.6.12
  2. rabbitmq3.8.6 JVM (e.g. java -version): java version "1.8.0_291"

we use logstash to recived msg from rabbitmq, and we create user ipanel, just only have read permissions, no config permissions, then refused for user 'ipanel'", :cause=>java.io.IOException

but ,if we give the ipanel config permissions,then connection is ok!

logstash config is input { rabbitmq { host => "192.168.3.9"
vhost => "/"
port => 5672
user => "ipanel" password => "123456" queue => "series" durable => true codec => "plain" }

Provide logs (if relevant): [2021-12-31T19:29:24,412][INFO ][logstash.inputs.rabbitmq ][main][6afa422247853f1c0e306f77456d68ccc69ab2c00ab11dbaf353d74e68d285d9] Connected to RabbitMQ {:url=>"amqp://ipanel:XXXXXX@localhost:5672/"} [2021-12-31T19:29:24,416][WARN ][logstash.inputs.rabbitmq ][main][6afa422247853f1c0e306f77456d68ccc69ab2c00ab11dbaf353d74e68d285d9] Error while setting up connection, will retry {:exception=>MarchHare::AccessRefused, :message=>"ACCESS_REFUSED - access to queue 'star' in vhost '/' refused for user 'ipanel'", :cause=>java.io.IOException}