找不到类 org.apache.kafka.abstracts.serialization.StringDeserializer [英] Class org.apache.kafka.abstracts.serialization.StringDeserializer could not be found

问题描述

我正在与 kafka 合作.并在描述中获取消息.我正在我的消费者类中设置反序列化器的属性.

I am working with kafka. and getting the message in the description. I am setting the properties for the deserializer in my consumer class.

props.put("key.deserializer",  "org.apache.kafka.abstracts.serialization.StringDeserializer");
props.put("value.deserializer",  "org.apache.kafka.abstracts.serialization.StringDeserializer");

producer = new KafkaProducer<>(props);

仍然在运行时我收到一个错误，说找不到解串器.我们最近从 10.0.1 升级到 10.1.1 是否有我遗漏的更改?

Still at runtime i'm getting an error that the deserializer could not be found. We recently upgraded to 10.1.1 from 10.0.1 is there a change in there that I am missing?

推荐答案

Kafka 的 String deserualizer 是'org.apache.kafka.common.serialization.StringDeserializer'

Kafka's String deserualizer is 'org.apache.kafka.common.serialization.StringDeserializer'

( https://github.com/apache/kafka/blob/0.10.0/clients/src/main/java/org/apache/kafka/common/serialization/StringDeserializer.java)

这篇关于找不到类 org.apache.kafka.abstracts.serialization.StringDeserializer的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！