我手动配置了StringDeserializer，启动任务后还是ByteArrayDeserializer，日志报错为
2021-07-08 16:57:12 WARN org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer09 -Ignoring configured key DeSerializer (key.deserializer)
2021-07-08 16:57:12 WARN org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer09 -Ignoring configured value DeSerializer (value.deserializer)
FlinkKafkaConsumer09忽略了反序列化配置这是什么问题呢，有大佬知道吗
这个问题需要修改引用的类，然后打包替换掉该类
手动配置序列化和反序列化
楼主找到为啥了吗？我也碰到了