刚入坑 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 控制台就不断的报错 全网也找不到对应的解决方案
(贴切的说百度搜索不到有用的结果)
overflow 也搜不到 基本也就告别这个世界了
但是知道的是 只有当开启事务 才会发生该异常 (控制台不断的报错)
最后想到最开始的异常信息
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.
我们翻译它
看到什么!?
broker 版本!
我马上想到 kafka的版本 我的是2.5.x
而我的meven 是最新的 现在是3.0
是的 一定是版本相差太大 而导致不兼容 这一点我在nodejs webpack深有研究
直接更换kafka为最新版 即可
ok:
kafka也能正常消费