我看了下我的配置,目前配置的是25秒,那我把这4个参数都设置下看看
The coordinator is not aware of this member.
这个错误一般是offset提交的时候,消息处理时间超过了30秒,kafka将该消费者从组中移除了,认为其已经无效。所以将组中移除,所以提交offset失败了。
可通过加大超时时间:
props.put(ConsumerConfig.SESSION_TIMEOUT_MS_CONFIG,60000);
props.put(ConsumerConfig.MAX_POLL_INTERVAL_MS_CONFIG,60000);
props.put(ConsumerConfig.FETCH_MAX_WAIT_MS_CONFIG,60000);
props.put(ConsumerConfig.REQUEST_TIMEOUT_MS_CONFIG,70000);
来解决这个问题。
相关的错误和解决方法和参考:https://www.orchome.com/6742
兄弟,问题还可以编辑的,不要写在这里哦。
重新编辑下,我正在看哦。