# Getting error while parsing logs from one server to another

**URL:** <https://discuss.elastic.co/t/getting-error-while-parsing-logs-from-one-server-to-another/371300>\
**Category:** Logstash\
**Created:** [December 2, 2024, 8:24am UTC](https://discuss.elastic.co/t/getting-error-while-parsing-logs-from-one-server-to-another/371300 "2024-12-02T08:24:27Z")\
**Posts on this page:** 2\
**Page:** 1

<div class="post-metadata">

**Author:** ![Monica\_D](https://sea2.discourse-cdn.com/elastic/user_avatar/discuss.elastic.co/monica_d/32/139631_2.png) [@Monica\_D](https://discuss.elastic.co/u/Monica_D)\
**Post date:** [December 2, 2024, 8:24am UTC](https://discuss.elastic.co/t/getting-error-while-parsing-logs-from-one-server-to-another/371300/1 "2024-12-02T08:24:27Z")

</div>

I have a setup with two Logstash servers, where the sender Logstash server takes input from a Python script and sends it to the receiving Logstash server. The port connectivity is fine, but I am still facing issues while sending data.

sending logstash server config-:

input {  
file {  
path =\> "/logfile.log" # Path to your log file  
start\_position =\> "beginning"  
sincedb\_path =\> "/dev/null"  
}  
}

filter {  
mutate {  
add\_field =\> { "hostname" =\> "${HOSTNAME}" }  
add\_field =\> { "date\_today" =\> "%{+YYYY-MM-dd}" }  
}  
}

output {  
tcp {  
host =\> "10.184.40.59" # Next Logstash server IP  
port =\> 5044  
codec =\> json\_lines # Optional: Use JSON encoding to make logs more structured  
}

# For debugging purpose, print to stdout (console)

stdout {  
codec =\> rubydebug # This prints the events in a readable format to the console  
}  
}

Receiving logstash server

input {  
tcp {  
port =\> 5044  
codec =\> plain { charset =\> "UTF-8" }  
}  
}

==================

Error-:

Dec 02 03:23:06 logtash logstash[46001]: [2024-12-02T03:23:06,663][ERROR][logstash.javapipeline][main][9cc307e68782a078e349837fd2aad43e13227477990e\>  
Dec 02 03:23:06 logtash logstash[46001]: Pipeline\_id:main  
Dec 02 03:23:06 logtash logstash[46001]: Plugin: \<LogStash::Inputs::Tcp codec=\>\<LogStash::Codecs::Plain charset=\>"UTF-8", id=\>"1594f87a-5028-4968-b63\>  
Dec 02 03:23:06 logtash logstash[46001]: Error: event executor terminated  
Dec 02 03:23:06 logtash logstash[46001]: Exception: Java::JavaUtilConcurrent::RejectedExecutionException  
Dec 02 03:23:06 logtash logstash[46001]: Stack: io.netty.util.concurrent.SingleThreadEventExecutor.reject(io/netty/util/concurrent/SingleThreadEventE\>  
Dec 02 03:23:06 logtash logstash[46001]: io.netty.util.concurrent.SingleThreadEventExecutor.offerTask(io/netty/util/concurrent/SingleThreadEventExecuto\>  
Dec 02 03:23:06 logtash logstash[46001]: io.netty.util.concurrent.SingleThreadEventExecutor.addTask(io/netty/util/concurrent/SingleThreadEventExecutor.\>  
Dec 02 03:23:06 logtash logstash[46001]: io.netty.util.concurrent.SingleThreadEventExecutor.execute(io/netty/util/concurrent/SingleThreadEventExecutor.\>  
Dec 02 03:23:06 logtash logstash[46001]: io.netty.util.concurrent.SingleThreadEventExecutor.execute(io/netty/util/concurrent/SingleThreadEventExecutor.\>  
Dec 02 03:23:06 logtash logstash[46001]: io.netty.channel.AbstractChannel$AbstractUnsafe.register(io/netty/channel/AbstractChannel.java:483)  
Dec 02 03:23:06 logtash logstash[46001]: io.netty.channel.SingleThreadEventLoop.register(io/netty/channel/SingleThreadEventLoop.java:87)  
Dec 02 03:23:06 logtash logstash[46001]: io.netty.channel.SingleThreadEventLoop.register(io/netty/channel/SingleThreadEventLoop.java:81)  
Dec 02 03:23:06 logtash logstash[46001]: io.netty.channel.MultithreadEventLoopGroup.register(io/netty/channel/MultithreadEventLoopGroup.java:86)  
Dec 02 03:23:06 logtash logstash[46001]: io.netty.bootstrap.AbstractBootstrap.initAndRegister(io/netty/bootstrap/AbstractBootstrap.java:323)  
Dec 02 03:23:06 logtash logstash[46001]: io.netty.bootstrap.AbstractBootstrap.doBind(io/netty/bootstrap/AbstractBootstrap.java:272)  
Dec 02 03:23:06 logtash logstash[46001]: io.netty.bootstrap.AbstractBootstrap.bind(io/netty/bootstrap/AbstractBootstrap.java:268)  
Dec 02 03:23:06 logtash logstash[46001]: io.netty.bootstrap.AbstractBootstrap.bind(io/netty/bootstrap/AbstractBootstrap.java:253)  
Dec 02 03:23:06 logtash logstash[46001]: org.logstash.tcp.InputLoop.run(org/logstash/tcp/InputLoop.java:86)  
Dec 02 03:23:06 logtash logstash[46001]: jdk.internal.reflect.GeneratedMethodAccessor14.invoke(jdk/internal/reflect/GeneratedMethodAccessor14)  
Dec 02 03:23:06 logtash logstash[46001]: jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(jdk/internal/reflect/DelegatingMethodAccessorImpl.jav\>  
Dec 02 03:23:06 logtash logstash[46001]: java.lang.reflect.Method.invoke(java/lang/reflect/Method.java:566)  
Dec 02 03:23:06 logtash logstash[46001]: org.jruby.javasupport.JavaMethod.invokeDirectWithExceptionHandling(org/jruby/javasupport/JavaMethod.java:441)  
Dec 02 03:23:06 logtash logstash[46001]: org.jruby.javasupport.JavaMethod.invokeDirect(org/jruby/javasupport/JavaMethod.java:305)  
Dec 02 03:23:06 logtash logstash[46001]: usr.share.logstash.vendor.bundle.jruby.$2\_dot\_5\_dot\_0.gems.logstash\_minus\_input\_minus\_tcp\_minus\_6\_dot\_2\_dot\_7\_\>  
Dec 02 03:23:06 logtash logstash[46001]: usr.share.logstash.logstash\_minus\_core.lib.logstash.java\_pipeline.inputworker(/usr/share/logstash/logstash-cor\>  
Dec 02 03:23:06 logtash logstash[46001]: usr.share.logstash.logstash\_minus\_core.lib.logstash.java\_pipeline.start\_input(/usr/share/logstash/logstash-cor\>  
Dec 02 03:23:06 logtash logstash[46001]: org.jruby.RubyProc.call(org/jruby/RubyProc.java:318)  
Dec 02 03:23:06 logtash logstash[46001]: java.lang.Thread.run(java/lang/Thread.java:829)

---

<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 30, 2024, 8:24am UTC](https://discuss.elastic.co/t/getting-error-while-parsing-logs-from-one-server-to-another/371300/2 "2024-12-30T08:24:31Z")

</div>

Closed on December 30, 2024, 8:24am UTC

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