apache-kafka - 如何查询 Kafka 主题以根据某些条件获取所有记录？

Question

我有一个 Kafka 主题，其中包含（时间戳，json）格式的记录。我正在编写一个 Spring Boot 应用程序，该应用程序需要查询主题以获取两个时间戳之间的所有可用记录。只是为了澄清..我想直接查询主题，而不是在使用这些记录并查询存储后以某种方式将记录保存在本地存储中。这可以使用流或任何其他方法完成吗？如果是这样，任何代码示例都将不胜感激。谢谢！

标签： apache-kafkakafka-consumer-apiapache-kafka-streamsspring-kafka