QueryableStoreRegistry被用来查询spring cloud stream中的状态存储，我不确定它是否可以查询远程状态存储？

文章/答案/技术大牛

发布

1回答

spring-cloud-stream

在kafka文档中，它说我们可以通过RPC查询状态存储。所以我不确定QueryableStoreRegistry是否能在spring cloud stream中获得同样的功能。

浏览 7提问于2019-05-10得票数 0

1回答

Kafka状态存储在分布式环境中不可用

spring-boot、spring-kafka、spring-cloud-stream

我有一个具有以下版本的业务应用程序 spring-cloud-stream-binder-kafka(2.2.1-RELEASE)spring-cloud-stream-binder-kafka-

浏览 1提问于2020-04-28得票数 0

回答已采纳

1回答

Spring Cloud Stream -查询主题而不显式消费KTable/KStream？

apache-kafka-streams、spring-cloud-stream、spring-cloud-stream-binder-kafka

我在一个Java应用程序中使用了Spring Cloud Stream库。我想为状态存储使用Kafka Streams绑定器。应用程序将向主题发布消息，我希望使用Kafka Streams InteractiveQueryService来检索同一主题中的数据。是否可以按原样执行这样的查询，或者我是否需要首先将主题作为KTable

浏览 36提问于2020-01-28得票数 0

1回答

在kstreams应用中使用自定义Kafka状态存储

java、apache-kafka、apache-kafka-streams、spring-cloud-stream、spring-cloud-stream-binder-kafka

dependencies { implementation 'org.springframework.cloud:spring-cloud-stream-binder-kafka-streams= 3, ports = {29901, 29902, 29903}, zookeeperPort = 33991) public class TestKafkaIntegration {

浏览 3提问于2020-08-08得票数 3

1回答

spring-kafka:在Spring Boot中使用交互式查询

spring-boot、apache-kafka-streams、spring-kafka

在Kafka Streams + Spring Boot应用程序中配置(提供主机和端口信息)和访问交互式查询的惯用方式是什么？访问KafkaStreams实例以访问状态存储的正确方法是什么？我知道spring-cloud-stream中有InteractiveQueriesService，但我并不是只在Spring Boot中使用spring-kafka库。谢

浏览 11提问于2020-10-17得票数 1

回答已采纳

1回答

如何在spring-cloud-stream中使用kafka过程拓扑中的交互式查询？

java、apache-kafka、apache-kafka-streams、spring-cloud-stream

是否可以在Spring Cloud Stream中使用带有@EnableBinding注释的类或带有@StreamListener的方法中的交互式查询(InteractiveQueryService)我的@StreamListener方法正在监听一堆KTables和KStreams，在处理拓扑的过程中，例如过滤，我必须检查来自K

浏览 16提问于2019-05-01得票数 1

回答已采纳

1回答

Kafka流绑定:无法获得状态存储，因为流线程是PARTITIONS_ASSIGNED，没有运行

apache-kafka、apache-kafka-streams、spring-cloud-stream

： destination: topicspring.cloud.stream.kafka.streams.binder.functions.filter.applicationId = <Id> IllegalStateException:检索状态</

浏览 1提问于2021-05-12得票数 2

1回答

Spring-Cloud-Stream process kafka消息仅在应用程序启动时实现的状态存储已完全填充并准备就绪后才能处理

java、spring-boot、apache-kafka、apache-kafka-streams、spring-cloud-stream

引用此solution，我的spring-cloud-stream application.yml文件具有以下配置： #application.yml spring.cloud.stream.bindings.input@EnableBinding注解的类以及带有@StreamListener注解的方法内部，我使用kafka stream DSL和处理器API集成来访问状

浏览 28提问于2019-05-09得票数 0

2回答

消费者的延迟启动，因为它依赖于尚未处于运行状态的MaterializedView

spring-cloud-stream

我有一个用例，在使用者内部，我使用一个物化视图来执行一些业务逻辑(如下面的代码所示)。在重新启动spring引导应用程序时，从kafka主题重新创建物化视图，这取决于主题上的消息，它可能需要很小的时间才能进入运行状态。如果在此延迟期间，消息到达对此MV具有依赖关系的另一个使用者执行其逻辑，则该消息失败。queryService.getQueryableStore(STORE_NAME, QueryableStoreTypes.keyValueStore())

浏览 4提问于2021-06-30得票数 0

回答已采纳

1回答

在卡夫卡流中创建全球国家商店(Spring)

spring、apache-kafka、apache-kafka-streams、spring-kafka、ktable

我是新卡夫卡，并试图创建一个小卡夫卡KTable实现。我已经成功地添加了一个KTable并能够进行查询。我曾经使用过当地的州立商店，它的运作就像预期的那样。我被几个问题弄糊涂了。要添加全局状态存储，我需要添加RPC端点 config.put(StreamsConfig.APPLICATION_SERVER_CONFIG, "127.0.0.1:8080&

浏览 4提问于2020-03-16得票数 1

1回答

我们可以在Kafka Streams中使用任何其他数据库，如MariaDB或MongoDB来代替Rocks DB来存储状态吗?有什么方法可以配置它吗？

mongodb、apache-kafka、apache-kafka-streams、spring-cloud-stream

我有一个Spring boot Kafka Stream应用程序，它处理所有传入的事件，并将其存储在Kafka Streams内部提供的State store中，并使用交互式查询服务进行查询。在所有这些使用" RocksDB“的Kafka流中，我想用任何其他可以配置的数据库替换这个RocksDB，比如MariaDB或M

浏览 21提问于2020-08-27得票数 4

1回答

KTable作为主题的输入，带有空键

spring-boot、apache-kafka、apache-kafka-streams、spring-cloud-stream

我是卡夫卡流的新手，遇到了一个问题。我有两个表-一个用于长期数据(descriptions)，另一个用于实时数据( live )。他们有共同的身份。其思想是存储来自 description 的数据(想必是在KTable中，为每个id保留最新的描述)，以及当新消息出现在live中时--将来自description的数据连接到相应的id上，并进一步发送为了简单起见，让我们让所有类型的

浏览 0提问于2020-05-19得票数 2

回答已采纳

1回答

无法从GemFire支持的会话中检索保存的对象

java、session、gemfire、spring-data-gemfire

我使用GemFire会话存储来保存和检索对象。用于保存和检索的会话id是相同的，但仍然检索null。任何帮助都是非常感谢的。

浏览 0提问于2018-09-19得票数 0

3回答

Spring数据(JPA)存储库线程安全吗？(又名SimpleJpaRepository线程安全)

java、jpa、spring-data、spring-data-jpa

我正在使用一个来处理CRUD样板。我定义我的存储库接口如下：{} 然后，Spring神奇地自动生成了一个上述接口的实现我

浏览 3提问于2013-04-12得票数 10

回答已采纳

0回答

使用Spring* Cloud Stream Kafka计算接收到的事件数据的聚合*

mongodb、apache-kafka、spring-cloud-stream

我刚刚开始使用Spring Cloud Stream Kafka。然后，计算出的聚合将通过请求-响应层在UI中提供。我<

浏览 5提问于2017-01-06得票数 0

1回答

Spring Cloud Config Server:配置git拉取间隔

spring、spring-boot、spring-cloud

我使用的是Spring Cloud Config Server，它通过BitBucket git存储库连接到Eureka Server。我在调试器下发现，每次配置服务器使用Eureka更新其状态时，都会通过调度器调用org.eclipse.jgit.api.PullCommand#call。此外，每当连接的服务查询更新的配置时，甚至在Spring Cloud co

浏览 4提问于2016-03-20得票数 4

2回答

JPA实体中的前后加载更新

java、spring、hibernate、jpa、orm

我在Spring和Hibernate中有项目。有两个JPA实体-用户和乔布斯。每个用户都有多个作业。每个职务都具有字段状态。创建新作业时，将向远程服务器发送新请求，并在状态进行时保存作业。通过使用远程服务器的ID，可以从远程服务器查询更新的状态。所请求的业务逻辑应该总是返回存储状态，但当作业处于in进度状态时

浏览 3提问于2014-12-04得票数 1

回答已采纳

1回答

在一个时间范围内查询Kafka流状态存储

apache-kafka、apache-kafka-streams

我想查询一个基于时间范围的Kafka流状态存储。用例是，我将使流处理器每30秒被调度一次。在每次调用期间，我希望查询一个状态存储，但只查询“新”项。我认为TimestampedKeyValueStore可能会有所帮助，但却找不到合适的API来实现它。是否可以根据时间范围(并保证一次准确地)<e

浏览 3提问于2020-07-22得票数 2

回答已采纳

2回答

用LINQ (C#)实现分页？

c#、sql-server、linq、sql-server-2008、linq-to-sql

我是数据库应用程序的新手。我所拥有的表由数千条记录组成，应用程序可以使用给定的标准查询记录。当前实现使用LINQ查询和整个数据将返回应用程序。如果查询返回的结果太多，可能会耗尽进程内存。因此，我想将其作为页面来实现。我在网上偶然看到了一些存储过程，这

浏览 3提问于2012-07-12得票数 3

1回答

单元测试Azure EventHub，流分析作业和存储表

unit-testing、azure、azure-table-storage、azure-eventhub

我正在做这个使用EventHub -> Stream Analytics Job -> Storage Table / Blob结构的项目，我想为它编写几个单元测试。我可以测试EventHub发件人状态，以查看查询是否具有预期的行为，但如何检查数据是否被发送到表存储，因为整个过程不会立即发生，而且从我访问EventHub<e

浏览 3提问于2016-03-22得票数 1

回答已采纳

点击加载更多