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

Posted to commits@flink.apache.org by li...@apache.org on 2022/01/25 09:45:16 UTC

[flink] branch master updated (9ab8dbd -> 8a694ca)

This is an automated email from the ASF dual-hosted git repository.

lindong pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.


    from 9ab8dbd  [FLINK-14954][rest] Add OpenAPI spec generator
     add 8a694ca  [FLINK-25702][Kafka] Use the configure feature provided by the kafka Serializer/Deserializer

No new revisions were added by this update.

Summary of changes:
 .../kafka/sink/KafkaRecordSerializationSchema.java |   6 +-
 .../KafkaRecordSerializationSchemaBuilder.java     |  24 +++--
 .../kafka/sink/KafkaSerializerWrapper.java         |  12 ++-
 .../KafkaRecordDeserializationSchema.java          |  15 ++-
 .../KafkaValueOnlyDeserializerWrapper.java         |   8 ++
 .../KafkaRecordSerializationSchemaBuilderTest.java | 105 ++++++++++++++++-----
 .../KafkaRecordDeserializationSchemaTest.java      |  69 ++++++++++++++
 7 files changed, 189 insertions(+), 50 deletions(-)