我和Kafka一起工作。从描述中得到信息。我正在为我的使用者类中的反序列化程序设置属性。
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，有什么我没有看到的变化吗？
1条答案
按热度按时间fcg9iug31#
kafka的字符串反序列化程序是'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 )