Kafka input plugin serialization

Elastic Stack Logstash
1

Hi there
in docs i was readed that serialization method of kafka pulgin is org.apache.kafka.common.serialization.Stringserializer and
org.apache.kafka.common.serialization.StringDeserializer
i want to use some other methods like ** Apache Avro** to compress (serialize and deserialize) data... and i am a python programmer (not java)

how can i change this default method?
thanks

2

another faq: can logstash7.3 and kafka input plugin support org.apache.avro ?

3

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