RabbitMQ output plugin

Elastic Stack Logstash
1

I am a new user for Logstash, and I want to use Logstash's RabbitMQ output plugin to feed data to RabbitMQ, schema is pretty simple:
Nginx -(input)->Logstash -(output)-> RabbitMQ

    cat /etc/logstash/conf.d/10-nginx-filter.conf
    filter {
       grok {
          match => { "message" => "%{IPORHOST:remote_ip} - %{DATA:user_name} \[%{HTTPDATE:access_time}\] \"%{WORD:http_method} %{DATA:url} HTTP/%{NUMBER:http_version}\" %{NUMBER:response_code} %{NUMBER:body_sent_bytes} \"%{DATA:referrer}\" \"%{DATA:agent}\"" }
       }
    }
    output {
      rabbitmq {
        exchange => "nginx_app"
        host => "localhost"
        exchange_type => "fanout"
        persistent => true
        passive => true
        key => "nginx_app"
        heartbeat => 10
      }
    }

I don't know why but I cannot see any message in the queue when I am connected to it,
What I am doing wrong?

2

I found a root cause, it was incorrect queue bindings on RabbitMQ side. Logstash's configuration was fine.

3

This topic was automatically closed 28 days after the last reply. New replies are no longer allowed.