MapReduce服务 MRS-为什么非static的KafkaPartitioner类对象去构造FlinkKafkaProducer010,运行时会报错:问题

时间:2023-11-01 16:19:45

问题

Flink内核升级到1.3.0之后,当Kafka调用带有非static的KafkaPartitioner类对象为参数的FlinkKafkaProducer010去构造函数时,运行时会报错。

报错内容如下:

org.apache.flink.api.common.InvalidProgramException: The implementation of the FlinkKafkaPartitioner is not serializable. The object probably contains or references non serializable fields.
support.huaweicloud.com/devg3-mrs/mrs_07_050051.html