Kafka错误-Magic xx does not suppor
2022-06-28 本文已影响0人
Alen_ab56
在使用spring client 连接kafka 0.10.1.1 的时候,报这个错误。显然是因为kafka client的版本比kafka集群高,导致版本不兼容。深层原因是:高版本的客户端使用了JSON serializer,这个方法在record headers添加了类型信息,但是< 0.11.0.0的kafka不支持,所以就报错了。
解决方式有两种:
1.关闭在头部添加类型信息;
2.对kafka客户端进行降级;