aljoscha opened a new pull request #8535: [FLINK-11693] Add KafkaSerializationSchema that uses ProducerRecord URL: https://github.com/apache/flink/pull/8535 This is a rebased and cleaned-up version of #7782 # What is the purpose of the change * Add a new serialization schema that directly uses `ProducerRecord`, thereby exposing all available Kafka functionality. ## Brief change log * We introduce the new schema, along with backwards-compatibility code in the different FlinkKafkaProducers * This extends the existing ITCases to also use the new serializer and still use the old serializer (side note, the Kafka tests are quite heavy and probably shouldn't be like this, but the aim of this PR is not to fix that.)
---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: [email protected] With regards, Apache Git Services
