Перехватить сообщение экспедитора logstash и переслать его в logstash
Я пытаюсь перехватить события журнала, перенаправленные с клиентского хоста, на котором запущен logstash-forwarder, на хост сервера, на котором запущен logstash (это может быть другая сеть). Конвейер работает нормально, используя плагин ввода дровосека с установленным ssl-сертификатом и ssl-ключом (logstash-2.4.0).
Однако теперь мне нужно перехватить событие на хосте (сервере) logstash, убедиться, что исходный хост является действительным клиентом на основе его IP-адреса, а затем переслать сообщение в том виде, как оно есть, в конвейер logstash.
Я пробовал входной плагин tcp logstash, но клиент терпит неудачу с сообщением Failed to tls handshake with XX.XX.XX.XX read tcp XX.XX.XX.XX:5043: i/o timeout,
Я также попытался запустить свой собственный сервер SSL, но он получает зашифрованное сообщение. Тем не менее, я могу получить исходный IP-адрес клиента с помощью этого подхода.
Есть ли способ добиться этого с помощью самого конвейера logstash и без необходимости запуска внешнего сервера, чтобы я мог избежать накладных расходов при работе с параллельными входящими клиентскими запросами?