org.apache.flink.connector.kafka org.apache.flink.connector.kafka.sink org.apache.flink.connector.kafka.source org.apache.flink.connector.kafka.source.enumerator org.apache.flink.connector.kafka.source.enumerator.initializer org.apache.flink.connector.kafka.source.enumerator.subscriber org.apache.flink.connector.kafka.source.metrics org.apache.flink.connector.kafka.source.reader org.apache.flink.connector.kafka.source.reader.deserializer org.apache.flink.connector.kafka.source.reader.fetcher org.apache.flink.connector.kafka.source.split org.apache.flink.streaming.connectors.kafka org.apache.flink.streaming.connectors.kafka.config org.apache.flink.streaming.connectors.kafka.internals org.apache.flink.streaming.connectors.kafka.internals.metrics org.apache.flink.streaming.connectors.kafka.partitioner org.apache.flink.streaming.connectors.kafka.shuffle org.apache.flink.streaming.connectors.kafka.table org.apache.flink.streaming.util.serialization