【发布时间】:2019-11-14 00:35:44
【问题描述】:
我无法让 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
我发现跟踪here 的类似问题。但我没有使用 Kafka Connect。还有
【问题讨论】:
标签: java apache-kafka avro confluent-schema-registry