java - 使用 Avro 序列化程序初始化 Kafka Producer 时出错：java.lang.NoClassDefFoundError

Question

我无法让 KafkaProducer 实例化为值序列化程序配置属性接受 avro 序列化程序。我安装kafka-avro-serializer-5.2.2.jar了

mvn install:install-file -DgroupId=io.confluent -DartifactId=kafka-avro-serializer \
    -Dversion=5.2.2 -Dpackaging=jar -Dfile=C:/Users/myuser/Downloads/kafka-avro-serializer-5.2.2.jar

jar 和相关文件已添加到~\.m2\repository\io\confluent\kafka-avro-serializer\5.2.2. 然后，我将以下内容添加到依赖项中的项目 POM 文件中：

<dependency>
    <groupId>io.confluent</groupId>
    <artifactId>kafka-avro-serializer</artifactId>
    <version>5.2.2</version>
</dependency>

然后我的客户中的以下导入工作正常；代码编译

import io.confluent.kafka.serializers.KafkaAvroSerializer;
import org.apache.kafka.clients.producer.KafkaProducer;
import org.apache.kafka.clients.producer.Producer;
import org.apache.kafka.clients.producer.ProducerConfig;

但是运行这个：

Properties props = new Properties();
props.put("bootstrap.servers", "localhost:9092");
props.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, StringSerializer.class.getName());
props.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, KafkaAvroSerializer.class.getName());

final Producer<String, Object> producer = new KafkaProducer<>(props);

结果错误：

Exception in thread "main" java.lang.NoClassDefFoundError: io/confluent/common/config/ConfigException

我在这里发现了一个类似的问题。但我没有使用 Kafka Connect。还

标签： javaapache-kafkaavroconfluent-schema-registry

Answer 1

您必须为通用配置添加一个依赖项。

<dependency>
    <groupId>io.confluent</groupId>
    <artifactId>common-config</artifactId>
    <version>5.2.2</version>
</dependency>

该类在此 JAR 中可用。