Spring Cloud流查询主题而不显式使用KTable/KStream？
我正在Java应用程序中使用Spring云流库。我想使用Kafka的Streams活页夹为一个国家商店。应用程序将向主题发布消息，我希望使用Kafka StreamsInteractiveQueryService从同一主题检索数据。是否可以按原样执行这样的查询，或者我需要首先将主题作为KTable/KStream消费并物化它，然后才能执行查询？我没有对主题执行KTable/KStream处理的任何要求，我只想查询主题内容。我希望有某种方法可以隐式地将它具体化为一个州存储。
共有1个答案
交互式查询是一个允许您查询客户端状态的功能。它不是允许您查询主题的功能。
因此，如果您希望使用“交互式查询”查询主题中的数据，则需要将数据加载到Kafka流中的状态存储中。
-
使用JPA2。0（通过Hibernate 4），我可以使用EntityManager在数据库中查询查询条件为主键的记录。查找（java.lang.Class entityClass，java.lang.Object primaryKey）。但是，如果查询条件不是主键（例如，选择city值为“london”的所有记录），我是否必须创建一个TypedQuery并显式提供SQL语句？我应该采取什么最佳做
-
问题内容： 如何检查查询是否出错，而不是向用户显示错误（包含不安全的数据库信息）。 假设我遇到这样的情况，我的分页类采用URI段显示page 。如果有人这样写，我将得到一个错误，显示有关我的数据库的信息。 我该如何处理？ 问题答案： 在application / config / database.php中设置 在模型或控制器中：
-
我正在实验Kafka流，我有以下设置： null 有什么方法可以让我的KTable从我的主题中“继承”保留策略吗？这样当记录从主主题过期时，它们在KTable中就不再可用了？ 我担心将所有记录转储到KTable中，并使StateStore无限增长。 我能想到的一个解决方案是转换成一个窗口流，其跳跃窗口等于记录的TimeToLive，但我想知道是否有更好的解决方案，以更原生的方式。 多谢了。
-
10. 查询主播流丢帧率 10.1. 功能 根据流名称查询主播推流的丢帧率，用于监控 10.2. 地址 http://api.bokecs.com/liveService/{domain}/{appname}/{streamname}/{page}/{rows}/{time}/{sign}/failRate 10.3. 请求参数 domain 客户加速域名，必填 appname App名称，如果查
-
我在Dropwizard中使用JDBI，但在流畅的查询方面遇到了问题。我有一个apiendpoint，如下所示： 我试图避免编写以下3个查询: 这也意味着，我的方法get帐户实现有3个如果检查…昵称和没有电子邮件，电子邮件和没有昵称，电子邮件和昵称，以确定要运行3个查询中的哪一个。如果我要添加另一个查找参数（例如，帐户ID），这意味着我现在需要6个查询（每种可能性1个）和6个if语句来确定要运行哪
-
但是我在遗留系统上有一个具有许多属性的对象，我只想选择几个，尽管我知道选择几个属性通常是很快的。 如果不使用条件查询，这可能吗？