我有一个应用程序，它可以将给定id和版本的消息（对于同一个id，可以有多个版本）发布到Kafka主题。这些消息由下游应用程序处理，下游应用程序发送回联系id和版本的响应。一旦我收到一条消息的响应，我想查询所有id和版本与我从下游收到的版本相同的消息。我能在Kafka身上做到吗？任何一个指针都是非常感谢的。
示例：publisher为版本为1-10的id1发布了10条消息，消费者消费了所有消息并发送到下游，下游以版本为5的id1响应，因此我想查询版本为1-5的id1消息