Caused by: java.io.NotSerializableException: org.apache.kafka.common.metrics.MetricConfig
flink 自定义数据源的开发过程中遇到这样一个错误。 错误原因：在于KafkaConsumer的初始化放在了定义处。 解决： 应该放在open方法内初始化。 DataStreamSource<String> dataStreamSource = env.addSource(new KafkaSourceFunction()); //获取数据 kafka消费数据获取 DataStreamSource<String&
