如果我的业务逻辑需要很长时间来处理第一个偏移量的数据,则 Kafka 不轮询偏移量属于同一分区

问题描述

我有场景,我正在从 kafka 轮询数据,并且我有通知服务,它是 kafka 消费者,它从 kafka 轮询数据,问题是在获取一个偏移量时,通知服务需要将近 5 分钟以上的时间来处理数据第一个偏移量,当下一次轮询发生时,它无法从同一分区获取数据 例如

分区 10 偏移 20 成功,业务逻辑耗时 5 分钟。和 分区 10 偏移量 21 ,无法获取,为空

Producer 成功推送数据。

谁能帮忙

解决方法

暂无找到可以解决该程序问题的有效方法,小编努力寻找整理中!

如果你已经找到好的解决方法,欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@)