有什么办法可以让我在Kafka中获得时间阈值相关的消息。例如，消费者从Kafka中提取一条消息，但是系统没有足够的信息来处理。因此，我将消息放回“解析器”队列中，但是我不想在接下来的15分钟内将其从“解析器”队列中拉出，有什么办法可以实现呢？
不，仅靠卡夫卡是无法实现这一目标的。Kafka旨在将消息存储一段时间或直到达到一定大小。从Kafka获取消息的唯一方法是偏移。偏移量标识哪些消息已被使用，偏移量之前的消息已被读取，偏移量之后的消息尚未被读取。
据我所知，Kafka没有提供带有消息的时间戳（对此我可能是错的）。但是通读文档并使用它已有几个月了，我从未遇到过有关根据时间从Kafka检索消息的任何示例。
本文收集自互联网，转载请注明来源。
如有侵权，请联系 [email protected] 删除。
我来说两句