问题

当我们运行一个程序报错class org.apache.kafka.common.serialization.StringSerializer is not an instance of org.apache.kafka.common.serialization.Deserializer

在这里插入图片描述

原因

class org.apache.kafka.common.serialization.StringSerializer 不是 org.apache.kafka.common.serialization.Deserializer 的实例
从而无法创建消费者
Failed to construct kafka consumer
在这里插入图片描述

解决

StringSerializer改为StringDeserializer
在这里插入图片描述
问题成功解决
在这里插入图片描述

感谢大家观看

Logo

大数据从业者之家,一起探索大数据的无限可能!

更多推荐