flink读取kafka报shaded ByteArrayDeserializer异常

	value.deserializer = class org.apache.flink.kafka.shaded.org.apache.kafka.common.serialization.ByteArrayDeserializer

2021-07-06 17:55:20,519 INFO  org.apache.flink.runtime.checkpoint.channel.ChannelStateWriteRequestExecutorImpl [] - Source: Custom Source -> Filter -> Sink: Unnamed (1/1)#223 discarding 0 drained requests
2021-07-06 17:55:20,519 WARN  org.apache.flink.runtime.taskmanager.Task                    [] - Source: Custom Source -> Filter -> Sink: Unnamed (1/1)#223 (0326263def4826d9563fef3519fed530) switched from RUNNING to FAILED.
org.apache.kafka.common.KafkaException: Failed to construct kafka consumer
	at org.apache.kafka.clients.consumer.KafkaConsumer.<init>(KafkaConsumer.java:820) ~[flink-app-jar.jar:?]
	at org.apache.kafka.clients.consumer.KafkaConsumer.<init>(KafkaConsumer.java:666) ~[flink-app-jar.jar:?]
	at org.apache.kafka.clients.consumer.KafkaConsumer.<init>(KafkaConsumer.java:646) ~[flink-app-jar.jar:?]
	at org.apache.flink.streaming.connectors.kafka.internals.KafkaPartitionDiscoverer.initializeConnections(KafkaPartitionDiscoverer.java:55) ~[flink-app-jar.jar:?]
	at org.apache.flink.streaming.connectors.kafka.internals.AbstractPartitionDiscoverer.open(AbstractPartitionDiscoverer.java:94) ~[flink-app-jar.jar:?]
	at org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumerBase.open(FlinkKafkaConsumerBase.java:551) ~[flink-app-jar.jar:?]
	at org.apache.flink.api.common.functions.util.FunctionUtils.openFunction(FunctionUtils.java:34) ~[flink-dist_2.11-1.12-vvr-3.0.2-SNAPSHOT.jar:1.12-vvr-3.0.2-SNAPSHOT]
	at org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator.open(AbstractUdfStreamOperator.java:102) ~[flink-dist_2.11-1.12-vvr-3.0.2-SNAPSHOT.jar:1.12-vvr-3.0.2-SNAPSHOT]
	at org.apache.flink.streaming.runtime.tasks.OperatorChain.initializeStateAndOpenOperators(OperatorChain.java:428) ~[flink-dist_2.11-1.12-vvr-3.0.2-SNAPSHOT.jar:1.12-vvr-3.0.2-SNAPSHOT]
	at org.apache.flink.streaming.runtime.tasks.StreamTask.lambda$beforeInvoke$2(StreamTask.java:543) ~[flink-dist_2.11-1.12-vvr-3.0.2-SNAPSHOT.jar:1.12-vvr-3.0.2-SNAPSHOT]
	at org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor$SynchronizedStreamTaskActionExecutor.runThrowing(StreamTaskActionExecutor.java:93) ~[flink-dist_2.11-1.12-vvr-3.0.2-SNAPSHOT.jar:1.12-vvr-3.0.2-SNAPSHOT]
	at org.apache.flink.streaming.runtime.tasks.StreamTask.beforeInvoke(StreamTask.java:533) ~[flink-dist_2.11-1.12-vvr-3.0.2-SNAPSHOT.jar:1.12-vvr-3.0.2-SNAPSHOT]
	at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:573) ~[flink-dist_2.11-1.12-vvr-3.0.2-SNAPSHOT.jar:1.12-vvr-3.0.2-SNAPSHOT]
	at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:755) [flink-dist_2.11-1.12-vvr-3.0.2-SNAPSHOT.jar:1.12-vvr-3.0.2-SNAPSHOT]
	at org.apache.flink.runtime.taskmanager.Task.run(Task.java:570) [flink-dist_2.11-1.12-vvr-3.0.2-SNAPSHOT.jar:1.12-vvr-3.0.2-SNAPSHOT]
	at java.lang.Thread.run(Thread.java:748) [?:1.8.0_252]
Caused by: org.apache.kafka.common.KafkaException: class org.apache.flink.kafka.shaded.org.apache.kafka.common.serialization.ByteArrayDeserializer is not an instance of org.apache.kafka.common.serialization.Deserializer
	at org.apache.kafka.common.config.AbstractConfig.getConfiguredInstance(AbstractConfig.java:374) ~[flink-app-jar.jar:?]
	at org.apache.kafka.common.config.AbstractConfig.getConfiguredInstance(AbstractConfig.java:392) ~[flink-app-jar.jar:?]
	at org.apache.kafka.clients.consumer.KafkaConsumer.<init>(KafkaConsumer.java:713) ~[flink-app-jar.jar:?]
	... 15 more

flink-connector-kafka_2.11-1.12.0.jar

flink-sql-connector-kafka_2.11-1.12.0.jar