问题描述
我有场景,我正在从 kafka 轮询数据,并且我有通知服务,它是 kafka 消费者,它从 kafka 轮询数据,问题是在获取第一个偏移量时,通知服务需要将近 5 分钟以上的时间来处理数据第一个偏移量,当下一次轮询发生时,它无法从同一分区获取数据
例如
分区 10 偏移 20 成功,业务逻辑耗时 5 分钟。和
分区 10 偏移量 21 ,无法获取,为空
Producer 成功推送数据。
谁能帮忙
解决方法
暂无找到可以解决该程序问题的有效方法,小编努力寻找整理中!
如果你已经找到好的解决方法,欢迎将解决方案带上本链接一起发送给小编。
小编邮箱:dio#foxmail.com (将#修改为@)