Kafka String Deserializer with Logstash

Hi everyone
I am getting a problem on pushing data from Kafka to Logstash and getting following problem.
first, my data type is JSON file, original data
I configured Kafka filesystem source connect to read JSON data and use following converters

The message stored in Kafka

Now on Logstash I want to decode the serialized data to original data and use json plugin to parse the data.

Could you please suggest me the best approach?

Thanks so much.

Hi, anyone can help?

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