共计 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");
正文完
发表至: Kafka
2017-10-24