Невозможно получить сообщение с многоканальным конвейером - PullRequest
Новая
       2

Невозможно получить сообщение с многоканальным конвейером

0 голосов
/ 04 марта 2020

Я хотел бы работать с 2 logsta sh, и я сделал настройку в файле pipe.yml Мой pipe.yml: 

pipeline.id: input_pipeline_1
path.config: "config/tcp.conf"
pipeline.workers: 3
pipeline.id: forward_to_ES_pipeline_1
path.config: "testC/test.conf"
queue.type: persisted

Я пытался получить сообщение из logstash1 с TCP-порт (например, 7979) и продолжить фильтрацию сообщений, затем отправить на порт (например, 5044), в то время как logstash2 получил сообщение от порта 5044 и отправил его в Elasticseach. Проблема выглядит так, как будто сообщение не может получить сообщение от 1-го logsta sh, потому что я пытаюсь отправить сообщение на порт 5044, а logstash2 может получить сообщение и перейти к Elasticsearch.

Logstash1 conf: 

input {
tcp {
port => 7979
host => "10.61.35.162"
}
}
filter {
  //Filtering log_msg
}
output {
tcp {
port => 5044
host => "10.61.35.162"
}
}

Logstash2.conf: 

input {
  tcp {
    port => 5044
    mode => "server"
  }
}
output {
  elasticsearch {
    hosts => ["http://10.61.35.162:9200/"]
    index => "work_pls"
  }
  stdout { codec => rubydebug }
}

Я также пробовал тот же порт с 2 logsta sh, но он также не работал. Как я могу решить проблемы?

** Я использую команду ncat для отправки сообщения на определенный порт. Пример команды 

echo Testing123 | ncat --send-only 10.61.35.162 <port number>

** Цель 2 logsta sh - я хочу проверить безопасность SSL и попытаться прослушать пакет для проверки безопасности связи.

...