Kafka input plugin serialization

Hi there
in docs i was readed that serialization method of kafka pulgin is org.apache.kafka.common.serialization.Stringserializer and
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?

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

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