使用过时的 kafka 消息根据时间表安排

今日不肯埋头，明日何以抬头！每日一句努力自己的话哈哈~哈喽，今天我将给大家带来一篇《使用过时的 kafka 消息根据时间表安排》，主要内容是讲解等等，感兴趣的朋友可以收藏或者有更好的建议在评论提出，我都会认真看的！大家一起进步，一起学习！

我们有一个用例，我们需要每五分钟消费一次来自 Kafka 主题的消息，这些消息至少一小时前。 可以使用kafka吗？

正确答案

根据您的 Kafka 客户端，您可以以编程方式使用 offsets_for_time 函数调用，然后在轮询之前将该信息传递到使用者实例的 seek 方法中。

您也可以使用 kafka-consumer-groups --reset-offsets CLI 执行相同的操作。

然而，不断寻找消费者可能并不是最好的模式；根据您的查询模式，转储到数据库或文件系统可能会更优化。

以上就是本文的全部内容了，是否有顺利帮助你解决问题？若是能给你带来学习上的帮助，请大家多多支持golang学习网！更多关于Golang的相关知识，也可关注golang学习网公众号。