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:
When running I get "class not found error"
How do I upload deserializer jar?