有没有什么办法，我可以在Kafka时间阈值相关的消息。e、 g.消费者从Kafka中提取消息，但系统没有足够的信息进行处理。所以我把消息放回“resolver”队列，但我不想在接下来的15分钟内把它从“resolver”队列中拉出来，有什么方法可以实现吗。
vecaoik11#
不，只有Kafka是不可能做到的。Kafka被设计用来存储信息一段时间或直到一定的大小。从Kafka那里得到信息的唯一方法是通过偏移量。偏移量标识哪些消息已被使用、偏移量之前的消息已被读取、偏移量之后的消息尚未被读取。据我所知，Kafka不提供时间戳的信息（我可能是错的）。但阅读文档并使用它几个月来，我从未遇到过任何基于时间从Kafka检索消息的例子。
1条答案
按热度按时间vecaoik11#
不，只有Kafka是不可能做到的。Kafka被设计用来存储信息一段时间或直到一定的大小。从Kafka那里得到信息的唯一方法是通过偏移量。偏移量标识哪些消息已被使用、偏移量之前的消息已被读取、偏移量之后的消息尚未被读取。
据我所知，Kafka不提供时间戳的信息（我可能是错的）。但阅读文档并使用它几个月来，我从未遇到过任何基于时间从Kafka检索消息的例子。