Tag: s3-kafka-connector

Question: I want to implement a custom s3 partitioner class to include some avro message fields and some extra logic to generate the output s3 path prefix The project is in kotlin, this is my class: at first I’ve tried ...