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