Transmiting raw event by logstash from kafka to kafka

For engineers Kafka real-time pipeline
1

Hi,

I want to transmit data of raw event from one Kafka to another Kafka by Logstash. But when the enrichment tries to enrich the events, the whole outputs go to enriched but with this error :

"errors":[{“level”:“error”,“message”:“Error deserializing raw event: Cannot read. Remote side has closed. Tried to read 2 bytes, but only got 1 bytes. (This is often indicative of an internal error on the server side. Please check your server logs.)”}]

my logstash config for serialization is :slight_smile:

input :

value_deserializer_class => “org.apache.kafka.common.serialization.ByteArrayDeserializer”

output :

value_serializer => “org.apache.kafka.common.serialization.ByteArraySerializer”

How Can I solve this error ?