将时间阈值与卡夫卡中的消息相关联

Question

有什么方法可以在 Kafka 中获得时间阈值关联消息。 例如。 消费者从 Kafka 中提取一条消息，但系统没有足够的信息来处理。所以我将消息放回 "resolver" 队列，但我不想在接下来的 15 分钟内将其从 "resolver" 队列中拉出，有什么办法可以做到这一点。

Answer 1

不，仅使用 Kafka 是无法实现的。 Kafka 旨在将消息存储一定时间或直到一定大小。从 Kafka 获取消息的唯一方法是通过偏移量。偏移量标识哪些消息已被消费，偏移量之前的消息已被读取，偏移量之后的消息尚未读取。

据我所知，Kafka 不为其消息提供时间戳（我可能错了）。但是阅读 documentation 并使用它几个月后，我从未遇到过任何有关根据时间从 Kafka 检索消息的示例。