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