小编Mni*_*usr的帖子

在kafka消费者中，如果消息的处理时间超过5分钟，则重新处理消息，我已配置消费者增加“max.poll.interval.ms”和session.timeout.ms

max.poll.interval.ms= 7200000 (2 小时) session.timeout.ms= 7200000 (2 小时) request.timeout.ms=7206000 (~2 小时)

这首先起作用，之后，它正在重新平衡我在消费者上遇到了这个错误

2019-10-18 15:29:51.739 INFO  o.a.k.c.c.i.AbstractCoordinator - [Consumer clientId=consumer-5, groupId=processgroup] (Re-)joining

Run Code Online (Sandbox Code Playgroud)

团体