# Logstash to logstash communication

**URL:** <https://discuss.elastic.co/t/logstash-to-logstash-communication/207164>\
**Category:** Logstash\
**Created:** [November 8, 2019, 7:51pm UTC](https://discuss.elastic.co/t/logstash-to-logstash-communication/207164 "2019-11-08T19:51:39Z")\
**Posts on this page:** 2\
**Page:** 1

<div class="post-metadata">

**Author:** ![Senthil\_ak](https://avatars.discourse-cdn.com/v4/letter/s/eb9ed0/32.png) [@Senthil\_ak](https://discuss.elastic.co/u/Senthil_ak)\
**Post date:** [November 8, 2019, 7:51pm UTC](https://discuss.elastic.co/t/logstash-to-logstash-communication/207164/1 "2019-11-08T19:51:39Z")

</div>

Hi,  
I am sending logs from one logstash to another through TCP or UDP. Earlier I tried with TCP i got error which posted at [https://discuss.elastic.co/t/eoferror-end-of-file-reached/204933](https://discuss.elastic.co/t/eoferror-end-of-file-reached/204933) so switched to UDP but now I am getting

```
org.jruby.exceptions.SystemCallError: (EMSGSIZE) Message too long - No message available
        at org.jruby.ext.socket.RubyUDPSocket.send(org/jruby/ext/socket/RubyUDPSocket.java:451) ~[jruby-complete-9.2.7.0.jar:?]
        at usr.share.logstash.vendor.bundle.jruby.$2_dot_5_dot_0.gems.logstash_minus_output_minus_udp_minus_3_dot_0_dot_6.lib.logstash.outputs.udp.register(/usr/share/logstash/vendor/bundle/jruby/2.5.0/gems/logstash-output-udp-3.0.6/lib/logstash/outputs/udp.rb:24) ~[?:?]
        at usr.share.logstash.vendor.bundle.jruby.$2_dot_5_dot_0.gems.logstash_minus_codec_minus_json_minus_3_dot_0_dot_5.lib.logstash.codecs.json.encode(/usr/share/logstash/vendor/bundle/jruby/2.5.0/gems/logstash-codec-json-3.0.5/lib/logstash/codecs/json.rb:42) ~[?:?]
        at usr.share.logstash.logstash_minus_core.lib.logstash.codecs.delegator.encode(/usr/share/logstash/logstash-core/lib/logstash/codecs/delegator.rb:31) ~[?:?]
        at org.logstash.instrument.metrics.AbstractSimpleMetricExt.time(org/logstash/instrument/metrics/AbstractSimpleMetricExt.java:45) ~[logstash-core.jar:?]
        at org.logstash.instrument.metrics.AbstractNamespacedMetricExt.time(org/logstash/instrument/metrics/AbstractNamespacedMetricExt.java:44) ~[logstash-core.jar:?]
        at usr.share.logstash.logstash_minus_core.lib.logstash.codecs.delegator.encode(/usr/share/logstash/logstash-core/lib/logstash/codecs/delegator.rb:30) ~[?:?]

```

And my logstash is keep-on restarting. I enable to the message size by adding small ruby code

```
ruby {
    code => "event.set('message_size', event.get('message').bytesize)"
}

```

No message is more that 65536, i am not sure how i can forward the logs now. any help will be appreciated. I checked in the network side there is no connection issue between the logstash when using UDP or TCP.

---

<div class="post-metadata">

**Author:** ![system](https://us1.discourse-cdn.com/elastic/original/3X/1/a/1ac57faf039f6b580b3f104ef42a2a89e41014de.png) [@system](https://discuss.elastic.co/u/system)\
**Post date:** [December 6, 2019, 7:51pm UTC](https://discuss.elastic.co/t/logstash-to-logstash-communication/207164/2 "2019-12-06T19:51:44Z")

</div>

This topic was automatically closed 28 days after the last reply. New replies are no longer allowed.