NXLog with Logstash using custom TAGS

I'm trying to send messages from NXLog into Logstash with a custom TAG. Logstash would filter those messages and then send them into specific topics in Kafka. For example my current Logstash + Filebeats works like that:

filebeat.yml has:

- /var/log/*.log

tags: ["EXAMPLE_1"]

Logstash.yml has :

AskedSeptember 6, 2018 - 11:53am

nxlog opening and orphaning tcp connections to logstash

Running version: nxlog-ce-2.9.1716
Logstash: 5.3.0

Nxlog opens and leaves open mutiple tcp connections to the logstash server. But on the nxlog client only one tcp connection is open.

I think Nxlog is doing something wrong because all the connections are all in the ESTABLISHED state so maybe its not gracefully closing them?

Is nxlog broken?

AskedJuly 6, 2017 - 10:01pm