You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user-zh@flink.apache.org by qq邮箱 <11...@qq.com> on 2019/09/17 09:55:16 UTC

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

在运行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.