kafka权威指南中用KafkaAvroSerializer进行序列化

    前两天拜读了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>

猜你喜欢

转载自blog.csdn.net/u014627099/article/details/83585862