是否可以在Spring Cloud Stream中使用带有@EnableBinding注释的类或带有@StreamListener的方法中的交互式查询(InteractiveQueryService)我尝试在提供的KStreamMusicSampleApplication类和进程方法中实例化ReadOnlyKeyValueStore，但总是为空。我的@StreamListener方法正在监听一堆KTables和KSt
浏览 16提问于2019-05-01得票数 1
回答已采纳
在Kafka Streams + Spring Boot应用程序中配置(提供主机和端口信息)和访问交互式查询的惯用方式是什么？ 访问KafkaStreams实例以访问状态存储的正确方法是什么？我知道spring-cloud-stream中有InteractiveQueriesService，但我并不是只在Spring Boot中使用spring-kafka库。 谢谢
浏览 11提问于2020-10-17得票数 1
回答已采纳
我想要有一个Kafka Streams拓扑，它将有五个独立的KStreams从各自的主题读取数据，并将数据转储到一个大型的整体主题中。我想让这个物化的全局存储基本上作为其他Kafka Streams应用程序的“查找”表。我已经阅读了一些关于使用带有application.server配置的RPC层来公开这一点的文章，该RPC层将以一些独特的host:port的形式
浏览 41提问于2020-11-11得票数 0
注解的类以及带有@StreamListener注解的方法内部，我使用kafka stream DSL和处理器API集成来访问状态存储，这些存储应该在应用程序启动时实现，因为application.yml)，但是消息仍然更早到达，并且正在由Kafka流拓扑处理，从而产生意外的结果。我们如何确保在第一个应用程序启动时，在@StreamListener中定义的任何流处理拓扑开始处理传入的消息之前，所有或特
浏览 28提问于2019-05-09得票数 0
我们的Apache拓扑使用KafkaSpout侦听来自Kafka的消息，在进行了大量映射/还原/浓缩/聚合等操作之后，最后将数据插入Cassandra。还有一个kafka输入，我们接收用户查询数据，如果拓扑找到一个响应，然后它发送到第三个kafka主题。现在我们想要使用Junit编写E2E测试，在这个测试中我们可以直接编程地将数据插入到拓扑中<
浏览 2提问于2019-07-12得票数 0
回答已采纳
我有一个应用程序是基于spring boot，spring-kafka和kafka-streams。当应用程序启动时，它使用默认的主题列表创建kafka streams拓扑。我需要做的是在运行时编辑/重新创建拓扑。例如，当应用程序已经运行时，有一个新的主题名称出现，我想将此主题添加到我的拓扑中。目前我正在考虑以某种方式删除现有的拓扑，关闭并清理Kafka
浏览 16提问于2020-04-11得票数 1
回答已采纳
从Kafka Streams 2.5.0开始，似乎拓扑必须包含一个输入主题。在Kafka 2.4.1 (及更早版本)中，情况并非如此。我有一个应用程序，其中的拓扑只是创建一些全局状态存储，这些存储从其他应用程序写入的主题中读取数据。在Kafka 2.5.0中，我得到了这个错误： 13:24:27.161 [<redacted>-7cf1b5c9-4a6e-4bf2-9f77-f7f85f2df3bb-StreamThrea
浏览 35提问于2020-04-21得票数 6
回答已采纳
1回答
我试着意识到在我的商业模式中使用Kafka流有什么好处。客户发布订单，并立即收到卖家的报价，谁是在线的，并在此订单无止境。在这种情况下，流适合加入可用的卖家(在线)订购流和过滤，排序(按价格)的报价。因此，客户应按要求按价格提供最佳报价。
我只发现了一个好处:服务器调用较少(所有计算都在流中进行)。我的问题是，为什么溪流在这种情况下是重要的？因为我可以使用一个单块应用程序的标准方法来完成这些业务步骤
浏览 3提问于2021-10-07得票数 1
回答已采纳
1回答
我有一个用spring云流和kafka流构建的流处理应用程序，这个系统从一个应用程序中获取日志，并将它们与另一个流处理器的观察结果进行比较并生成一个分数，然后日志流被分割成分数(高于&低于某个阈值)。拓扑：问题：所以我想出了两个解决方案..。(问题:对所有观察进行评分可能比窗口花费的时间更长)在每
浏览 1提问于2020-03-27得票数 0
回答已采纳
1回答
我对从Stream内部调用交互式查询有一个特殊的要求。这是因为我需要创建一个新的Stream，它应该在State Store中包含数据。topic.getTransformedStoreName(),在最后一行中，要访问State Store，我需要在创建KafkaStreams对象时拥有KafkaStreams对象和拓扑。这种方法的问
浏览 0提问于2019-02-21得票数 2
我在一个Java应用程序中使用了Spring Cloud Stream库。我想为状态存储使用Kafka Streams绑定器。应用程序将向主题发布消息，我希望使用Kafka Streams InteractiveQueryService来检索同一主题中的数据。是否可以按原样执行这样的查询，或者我是否需要首先将主题作为KTable/KStream使用并物化它，然后才能执行查询？我不需要对topic进行KTab
浏览 36提问于2020-01-28得票数 0
2回答
由于我的应用程序是专注于卡夫卡流，我需要使用交互式查询和查询我的状态商店，我想知道：有什么特别的方式来访问卡夫卡流状态商店与Spring ？据我所见，流对交互式查询有一定的支持，但我在Spring中找不到任何关于它们的信息。我是错过了什么，还是在春天没有得到支持-卡夫卡？如果是这样的话--在创建我自己版本的org.springframework.cloud.stream.binde
浏览 1提问于2019-01-10得票数 1
我有一个Spring boot Kafka Stream应用程序，它处理所有传入的事件，并将其存储在Kafka Streams内部提供的State store中，并使用交互式查询服务进行查询。在所有这些使用" RocksDB“的Kafka流中，我想用任何其他可以配置的数据库替换这个RocksDB，比如MariaDB或MongoDB。有办
浏览 21提问于2020-08-27得票数 4
1回答
我使logging.level.org.springframework.kafka.config=debug能够验证正在生成的拓扑，并发现了许多根本没有意义的节点。，这样一个简单的KStream声明会生成这个复杂的拓扑：
2019-04-30 23:47:03.881 DEBUG 2944 --- [ main] o.s.k.config.StreamsBuilderFactoryBeanKSTREAM-PROCESSOR-0000000006 (s
浏览 2提问于2019-04-30得票数 1
回答已采纳
当需要时，我想从这个主题中获取给定机器的最新连接信息。使用KTable可以做到这一点吗？如果是，请举例说明。我使用的是kafka 1.1.0
浏览 0提问于2019-07-17得票数 0
越来越多的文章将kafka作为事件存储，并将其用于使用cqrs和事件源构建的应用程序中。如何在kafka (作为事件存储库)查询某个聚合的事件，以完成写入端的操作？
浏览 1提问于2016-10-15得票数 4
应用程序的外观如下：流2: Topic2 + Topic3 joined > Topic4我尝试过不同的方法，比如TestChannelBinder，但是这种方法只适用于简单的函数，而不是流和Avro。我决定将EmbeddedKafka与MockSchemaRegistryClient结合使用。我可以生成一个主题，也可以再次使用同一个主题(topic1)，但我无法从(topic2)中使用
浏览 4提问于2021-08-20得票数 0
回答已采纳
1回答
我正在编写一个使用Apache v1.1.2、Kafka v0.11.0.1、ZooKeep3.4.6、Eureka和Config的文档化Java Spring应用程序，这些应用程序都是在Docker容器中编写的我在KafkaSpout中接收到的元组有一个"value“字段，它是一个protobuf对象。我使用自定义反序列化器将我的对象从它中提取出来进行处理。我有一个基本的应用程序，我有一个螺栓打印传入<e
浏览 1提问于2018-08-16得票数 0
回答已采纳
如何在Spark Structured Streaming中读取Kafka和查询外部存储，如Cassandra？我从Kafka获得消息流，我想对它应用Map操作，对于每个键，我想查询像Cassandra这样的数据存储，并获得该键的更多信息，并在流上应用进一步的操作。我如何使用Spark Structured Streaming 2.2.0来做到这一点？
浏览 2提问于2017-09-07得票数 1
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
云直播活动推荐
腾讯云开发者
