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");