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(-)
