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

共计 227 个字符，预计需要花费 1 分钟才能阅读完成。

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

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

serializer.class
部分，错误的当成了 StringEncoder，其实修改成默认的 encoder 就行了 

props.put("serializer.class", "kafka.serializer.DefaultEncoder");