Spring Cloud Stream-查询主题，而没有显式使用KTable / KStream吗？

Question

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

Answer 1

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

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