Kafka

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客户端进行降级;

上一篇 下一篇

猜你喜欢

热点阅读