This is an automated email from the ASF dual-hosted git repository.
dwysakowicz pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from de9ad1b [FLINK-17497][e2e] Properly switch to Scala 2.12 in
quickstart test
add 9f525f3 [hotfix][kafka] Remove unused method
AbstractFetcher#emitRecord
add fb9d864 [FLINK-17307] Add collector to deserialize in
KafkaDeserializationSchema
No new revisions were added by this update.
Summary of changes:
.../connectors/kafka/internal/Kafka010Fetcher.java | 59 +++++---
.../streaming/connectors/kafka/Kafka010ITCase.java | 5 +
.../streaming/connectors/kafka/Kafka011ITCase.java | 5 +
.../kafka/KafkaDeserializationSchema.java | 18 +++
.../kafka/internals/AbstractFetcher.java | 159 +++++++--------------
.../KafkaDeserializationSchemaWrapper.java | 11 +-
.../connectors/kafka/KafkaConsumerTestBase.java | 106 ++++++++++++++
.../kafka/internals/AbstractFetcherTest.java | 119 +++++++++------
.../connectors/kafka/internal/KafkaFetcher.java | 59 ++++++--
.../streaming/connectors/kafka/KafkaITCase.java | 5 +
10 files changed, 366 insertions(+), 180 deletions(-)
