java.lang.IllegalArgumentException: Magic v0 does not support record headers
一般是message.format.version引起的,消息的格式版本,我不太清楚你干了些什么,但是你的数据格式已经不对了。
message.format.version
大佬 我复现这个问题了 是因为消费端版本太低 正好前几天加了zipkin服务 zipkin连接kafka 在生产消息时会带上header 提高消费端版本就解决了
找不到想要的答案?提一个您自己的问题。
0 声望
这家伙太懒,什么都没留下
一般是
message.format.version
引起的,消息的格式版本,我不太清楚你干了些什么,但是你的数据格式已经不对了。大佬 我复现这个问题了 是因为消费端版本太低 正好前几天加了zipkin服务 zipkin连接kafka 在生产消息时会带上header 提高消费端版本就解决了
你的答案