乐趣区

kafka [B cannot be cast to java.lang.String

自己写了一个 Kafka 发送消息的 demo,但是发送消息的时候,却报了 kafka [B cannot be cast to java.lang.String 的错误,后来找到了解决办法

原来是因为在定义 config 文件的时候,针对

serializer.class
部分,错误的当成了 StringEncoder,其实修改成默认的 encoder 就行了 
props.put("serializer.class", "kafka.serializer.DefaultEncoder");
退出移动版