大佬策菜,我版本是zeppelin 0.10.0 flink 1.12.1 創(chuàng)建kafka流表讀取消息報(bào)Caused by: org.apache.kafka.common.KafkaException: class 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)
at org.apache.kafka.common.config.AbstractConfig.getConfiguredInstance(AbstractConfig.java:392)
at org.apache.kafka.clients.consumer.KafkaConsumer.<init>(KafkaConsumer.java:713)
... 15 more這個(gè)錯(cuò)茧吊。這是為啥啊
Flink SQL 1.11 on Zeppelin集成指南前言 大數(shù)據(jù)領(lǐng)域SQL化開發(fā)的風(fēng)潮方興未艾(所謂"Everybody knows SQL"),F(xiàn)link自然也不能“免俗”糟把。Flink SQL是Flink系統(tǒng)內(nèi)部最高級(jí)別的A...