You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@flink.apache.org by GitBox <gi...@apache.org> on 2019/05/24 09:37:14 UTC

[GitHub] [flink] aljoscha opened a new pull request #8535: [FLINK-11693] Add KafkaSerializationSchema that uses ProducerRecord

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:
users@infra.apache.org


With regards,
Apache Git Services