KafkaAvroDeserializer - NoClassDefFoundError: io/confluent/config/config/ConfigException

Question

我用火花从一个话题得到数据卡夫卡。我必须用KafkaAvroDeserialaizer反序列化avro数据。我配置kafka消费者，因此：

 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);

但是，当我执行代码时，线程中有此异常。

“流-启动”java.lang.NoClassDefFoundError: io/confluent/config/config/ConfigException

有人能告诉我在哪里能找到这个班长吗？例如，maven依赖项ext。

Answer 1

您需要以下依赖关系: group：'io.confluent'，名称：‘config’，version: yourConfluentVersion

Answer 2

我也有同样的问题。我使用了5.1.0汇流平台版本。我检查了kafka <-> confluent，发现在相同的兼容性级别上有更新的版本。我将版本更新到5.1.1，它为我解决了这个问题。

例如：

​

​