apache-kafka-streams - Spring Cloud Stream - 在不明确使用 KTable/KStream 的情况下查询主题？

Question

我在 Java 应用程序中使用 Spring Cloud Stream 库。我想将 Kafka Streams 活页夹用于状态存储。该应用程序将向主题发布消息，我希望使用 Kafka StreamsInteractiveQueryService从同一主题中检索数据。是否可以按原样执行此类查询，还是我需要先将主题作为 KTable/KStream 使用并在执行查询之前将其具体化？我没有对主题进行KTable/KStream处理的任何要求，我只想查询主题内容。我希望有某种方法可以将其隐式实现为状态存储。

Answer 1

交互式查询是一项允许您查询客户端状态状态的功能。它不是允许您查询主题的功能。

因此，如果您想使用“交互式查询”查询某个主题中的数据，则需要将数据加载到 Kafka Streams 中的状态存储中。