KafkaConsumer初始化遇到的问题
class org.apache.kafka.common.serialization.StringSerializer is not an instance of org.apache.kafka.common.
·
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>
更多推荐
已为社区贡献1条内容
所有评论(0)