public abstract class KafkaAvroTableSource extends KafkaTableSource
StreamTableSource
.
The version-specific Kafka consumers need to extend this class and
override KafkaTableSource.getKafkaConsumer(String, Properties, DeserializationSchema)
}.
explainSource, getDataStream, getDeserializationSchema, getReturnType
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.