Type Members

1.  class FlinkConsumerRecordBasedKafkaSource[K, V] extends FlinkKafkaSource[ConsumerRecord[K, V]]
2.  class FlinkKafkaConsumerHandlingExceptions[T] extends FlinkKafkaConsumer[T] with LazyLogging

   Annotations

   @silent("deprecated")

3.  class FlinkKafkaSource[T] extends StandardFlinkSource[T] with Serializable with FlinkSourceTestSupport[T] with RecordFormatterBaseTestDataGenerator with TestWithParametersSupport[T]
4.  class FlinkKafkaSourceImplFactory[K, V] extends KafkaSourceImplFactory[K, V] with Serializable