logstash 消费rabbitMQ中的消息 如何配置

您可以按照以下步骤来配置Logstash消费RabbitMQ中的消息：

1. 安装Logstash插件rabbitmq：

bin/logstash-plugin install logstash-input-rabbitmq

2. 在Logstash配置文件中配置input：

input {
  rabbitmq {
    host => "your_host"
    port => 5672
    user => "your_user"
    password => "your_password"
    queue => "your_queue_name"
    durable => true
    exclusive => false
    auto_delete => false
    ack => true
    heartbeat => 30
  }
}

3. 通过配置output将消息存储到Elasticsearch中：

output {
  elasticsearch {
    hosts => ["localhost:9200"]
    index => "your_index_name"
  }
}

以上是Logstash消费RabbitMQ中的消息的基本配置，您可以根据具体需求进行调整。