如何解决如果我的业务逻辑需要很长时间来处理第一个偏移量的数据,则 Kafka 不轮询偏移量属于同一分区
我有场景,我正在从 kafka 轮询数据,并且我有通知服务,它是 kafka 消费者,它从 kafka 轮询数据,问题是在获取第一个偏移量时,通知服务需要将近 5 分钟以上的时间来处理数据第一个偏移量,当下一次轮询发生时,它无法从同一分区获取数据 例如
分区 10 偏移 20 成功,业务逻辑耗时 5 分钟。和 分区 10 偏移量 21 ,无法获取,为空
Producer 成功推送数据。
谁能帮忙
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。