我正在使用 spark 從主題 kafka 獲取數(shù)據(jù)。我必須使用 KafkaAvroDeserialaizer 來(lái)反序列化 avro 數(shù)據(jù)。我這樣配置 kafka 消費(fèi)者： kafkaParams.put("bootstrap.servers", "10.0.4.215:9092"); kafkaParams.put("key.deserializer", io.confluent.kafka.serializers.KafkaAvroDeserializer.class); kafkaParams.put("value.deserializer",io.confluent.kafka.serializers.KafkaAvroDeserializer.class); // kafkaParams.put("key.convert", com.datamountaineer.streamreactor.connect.converters.source.JsonSimpleConverter.class); //kafkaParams.put("value.convert",com.datamountaineer.streamreactor.connect.converters.source.JsonSimpleConverter.class); kafkaParams.put("group.id", "use_a_separate_group_id_for_each_stream"); kafkaParams.put("auto.offset.reset", "earliest"); kafkaParams.put("enable.auto.commit", false);但是當(dāng)我執(zhí)行代碼時(shí)，我在線程中有這個(gè)異常異?！傲鏖_始” java.lang.NoClassDefFoundError: io/confluent/common/config/ConfigException有人能告訴我在哪里可以找到這個(gè)類的定義嗎？例如 maven 依賴 ext。
2 回答
jeck貓
TA貢獻(xiàn)1909條經(jīng)驗(yàn) 獲得超7個(gè)贊
您需要以下依賴項(xiàng)：組：'io.confluent'，名稱：'common-config'，版本：yourConfluentVersion
精慕HU
TA貢獻(xiàn)1845條經(jīng)驗(yàn) 獲得超8個(gè)贊
我有同樣的問題。我使用了5.1.0融合平臺(tái)版本。我檢查了兼容性kafka <-> confluent，發(fā)現(xiàn)在相同級(jí)別的兼容性中還有更新的版本。我更新了版本5.1.1，它為我解決了這個(gè)問題。
舉個(gè)例子：
添加回答
舉報(bào)
0/150
提交
取消