在 logstash 中使用来自 rabbitmq 的消息

Question

我试图从 logstash 读取 rabbitmq 队列中的日志，然后将其传递给 elasticsearch。但没有成功。这是我的 logstash 配置。

input {
    rabbitmq {
        host => "localhost"
        port => 15672
        heartbeat => 30
        durable => true
        exchange => "logging_queue"
        exchange_type => "logging_queue"
    }
}
output {
    elasticsearch {
        hosts => "localhost:9200"
    }
    stdout {}
}

但是没有创建索引，所以我在 Kibana 中当然看不到任何日志

队列中有一些消息

Answer 1

我认为正确的（默认）端口是 5672，因为 15672 是 Web 管理控制台的端口。

input {
    rabbitmq {
        host => "localhost"
        port => 5672                  <--- change this
        heartbeat => 30
        durable => true
        exchange => "logging_queue"
        exchange_type => "logging_queue"
    }
}
output {
    elasticsearch {
        hosts => "localhost:9200"
    }
    stdout {}
}