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.v2 org.apache.flink.streaming.connectors.kafka.v2.common org.apache.flink.streaming.connectors.kafka.v2.common.util org.apache.flink.streaming.util.serialization org.apache.flink.table.descriptors