在使用spring client 连接kafka 0.10.1.1 的时候,报这个错误。显然是因为kafka client的版本比kafka集群高,导致版本不兼容。深层原因是:高版本的客户端使用了JSON serializer,这个方法在record headers添加了类型信息,但是< 0.11.0.0的kafka不支持,所以就报错了。
解决方式有两种:
1.关闭在头部添加类型信息;
2.对kafka客户端进行降级;
在使用spring client 连接kafka 0.10.1.1 的时候,报这个错误。显然是因为kafka client的版本比kafka集群高,导致版本不兼容。深层原因是:高版本的客户端使用了JSON serializer,这个方法在record headers添加了类型信息,但是< 0.11.0.0的kafka不支持,所以就报错了。
解决方式有两种:
1.关闭在头部添加类型信息;
2.对kafka客户端进行降级;
本文标题:Kafka错误-Magic xx does not suppor
本文链接:https://www.haomeiwen.com/subject/ipuavrtx.html
网友评论