刚入坑 kafka 遇到的一个问题

 Broker doesn't support group metadata commit API on version 2, minimum supported request version is 3 which requires brokers to be on version 2.5 or above.

Cannot execute transactional method because we are in an error state
大概就是说事务提交失败

启动spring 控制台就不断的报错 全网也找不到对应的解决方案
(贴切的说百度搜索不到有用的结果)
2023-07-16T01:00:46.png

overflow 也搜不到 基本也就告别这个世界了

2023-07-16T01:01:15.png

但是知道的是 只有当开启事务 才会发生该异常 (控制台不断的报错)

2023-07-16T01:02:59.png

最后想到最开始的异常信息

 Broker doesn't support group metadata commit API on version 2, minimum supported request version is 3 which requires brokers to be on version 2.5 or above.

我们翻译它

2023-07-16T01:05:25.png

看到什么!?
broker 版本!
我马上想到 kafka的版本 我的是2.5.x

而我的meven 是最新的 现在是3.0

2023-07-16T01:08:05.png

是的 一定是版本相差太大 而导致不兼容 这一点我在nodejs webpack深有研究

直接更换kafka为最新版 即可

ok:
2023-07-16T01:09:40.png

kafka也能正常消费

2023-07-16T01:16:02.png

最后 提供一个来自官网的 Kafka 客户端和 Spring Boot 兼容性

2023-07-16T01:14:11.png

最后修改:2023 年 07 月 16 日
如果觉得我的文章对你有用,请随意赞赏