前两天拜读了Kafka权威指南一书,比着书里的示例抄代码的时候发现第三章里用: kafkaProps.put("key.serializer", "io.confluent.kafka.serializers.KafkaAvroSerializer"); 进行序列化时maven找不到KafkaAvroSerializer包,我在maven官方respository里也没找到,后来发现需要在pom.xml里添加如下repository和dependency: <repositories> <repository> <id>confluent</id> <url>http://packages.confluent.io/maven/</url> </repository> </repositories> <dependency> <groupId>io.confluent</groupId> <artifactId>kafka-avro-serializer</artifactId> <version>1.0</version> <!-- Also tried 2.0-SNAPSHOT --> </dependency>
kafka权威指南中用KafkaAvroSerializer进行序列化
猜你喜欢
转载自blog.csdn.net/u014627099/article/details/83585862
今日推荐
周排行