python-logstash not working
<p>I have an elasticsearch cluster (ELK) and some nodes sending logs to the logstash using filebeat.<br>
Lately I added a new application server, who is sending logs to my logstash using <code>python-logstash</code>.</p>

<p>My logstash input configuration looks something like this :</p>

<pre><code>input {
   beats {
     type =&gt; beats
     port =&gt; 5044
   }
   udp {
     port =&gt; 5044
   }
}
</code></pre>

<p>My application server sends the logs successfully to the logstash. On my logstash machine I tried to run the following command:</p>

<pre><code>tcpdump -nn | grep x.x.x.x
</code></pre>

<p><code>x.x.x.x</code> is the ip of my application server.</p>

<p>My code is :</p>

<pre><code>self.logger=logging.getLogger(logger_name)
self.logger.addHandler(logstash.UDPLogstashHandler(ELASTICSEARCH_LOGSTASH_SERVER, 5044, version=1, message_type='bla',fqdn=elastic_fqdn))
</code></pre>

<p>elastic_fqdn is the hostname of the hosted server.</p>

<p>I was able to see the packets, they looked fine (<code>udp</code>, port 5044), but I couldn't see any document in my kibana/elasticsearch.</p>

<p>Thanks for your help :)</p>