写入到Kafka的时候报错ByteArraySerializer could not be found.

[qq邮箱]

在运行flink写入到kafka的时候提示如下错误

org.apache.kafka.common.config.ConfigException: Invalid value org.apache.flink.kafka.shaded.org.apache.kafka.common.serialization.ByteArraySerializer for configuration key.serializer: Class org.apache.flink.kafka.shaded.org.apache.kafka.common.serialization.ByteArraySerializer could not be found.