不是一个错误,但我确实看到了这一行,根据消息可能会影响性能: 2019-01-02 14:44:44,879 INFO org.apache.flink.api.java.typeutils.TypeExtractor- class org.apache.flink.streaming.connectors.kafka.internals.KafkaTopicPartition
does- Class class org.apache.flink.streaming.connectors.kafka.