Custom jar deployment

Elastic Stack Logstash
1

Hello. I am trying to consume kafka topics and output them to s3. All works when we consume topics published in Avro, but we are struggling to make it working for JSON topics. I understood there is an option of using specific deserialization class and set it in "value_deserializer_class" string property like this:

value_deserializer_class: "io.confluent.kafka.serializers.KafkaJsonDeserializer".

When running I get "class not found error"

How do I upload deserializer jar?

Thanks?

2

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