Package org.apache.flink.connector.kafka.source.reader

Class Summary

Class	Description
KafkaPartitionSplitReader	A SplitReader implementation that reads records from Kafka partitions.
KafkaRecordEmitter<T>	The RecordEmitter implementation for KafkaSourceReader.
KafkaSourceReader<T>	The source reader for Kafka partitions.