kafka在线修改副本,删除了数据目录,启动一段时间后报错

顾不到弄么多 发表于: 2020-06-05   最后更新时间: 2020-12-01 10:46:18   1,315 游览
java.lang.IllegalArgumentException: Magic v0 does not support record headers
发表于 2020-06-05
添加评论

一般是message.format.version引起的,消息的格式版本,我不太清楚你干了些什么,但是你的数据格式已经不对了。

大佬 我复现这个问题了 是因为消费端版本太低 正好前几天加了zipkin服务 zipkin连接kafka 在生产消息时会带上header 提高消费端版本就解决了

你的答案

查看kafka相关的其他问题或提一个您自己的问题