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