1)报错:class org.apache.kafka.common.serialization.StringSerializer is not an instance of org.apache.kafka.common.deserializer
解决:

Properties properties = new Properties(); 
properties.put(ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class.getName()); 
properties.put(ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class.getName());

2) 报错: com.fasterxml.jackson.databind.JsonNode

解决:

<dependency>
 <groupId>com.fasterxml.jackson.core</groupId>
  <artifactId>jackson-databind</artifactId>
  <version>2.9.5</version>
</dependency>

 

Logo

为开发者提供学习成长、分享交流、生态实践、资源工具等服务,帮助开发者快速成长。

更多推荐