运行在kubernetes上的Kafka-Broker。一个SpringBoot-应用程序与kafka-streams和一个输入-主题作为KSteram。我像这样读取了所有的键/值对 private ReadOnlyKeyValueStore<String, PriceDomain> keyValueStore;
public List<PriceModel当然，大多数时候我可以通过键直接访问这个值，这会很快。但有时我需要所有的键/值对。 假设将来会有更多的键&#x
浏览 37提问于2020-09-18得票数 0
回答已采纳
但是，在重新启动streams应用程序时，我能够看到更新的状态。如何在不重新启动的情况下运行流应用程序时获取更新的状态。 try {
metaTableView = waitUntilStoreIsQueryabl
浏览 1提问于2018-06-19得票数 0
回答已采纳
1回答
当我试图从流访问状态存储时，我得到了以下错误。当我试图从商店访问ReadOnlyKeyValueStore时，当迁移到其他服务器时，会得到错误消息。import org.apache.kafka.streams.StreamsBuilder;import;
import org.apache.kafka.<e
浏览 1提问于2019-04-03得票数 2
1回答
我们使用的是春季云流Hoxton RC7项目中包含的Kafka流(因此使用了Kafka-streams和Kafka-client版本，提供了2.3.1)。// spring cloud streamReadOnlyKeyValueStore<String, F
浏览 3提问于2020-08-08得票数 3
1回答
参考本文档的4.2.6没有春天你还能做什么？.;KafkaStreams streams = new KafkaStreams(builder, config);
ReadOnlyKeyValueStore<String, Long
浏览 2提问于2018-09-01得票数 3
回答已采纳
我有一个函数，它接受Kafka streams的一个实例，获取状态存储，解析它并进行一些计算。void func1(KafkaStreams streams) StoreQueryParameters<ReadOnlyKeyValueStore<String, Long>> storeQueryParams= ReadOnlyKeyValueStore</e
浏览 24提问于2020-10-09得票数 0
当我尝试使用ReadOnlyKeyValueStore访问存储时，我得到了以下异常，尽管几分钟前我存储了一些对象ReadOnlyKeyValueStore<String, Customer> customerStore = streams.store("customer", QueryableStoreTypes.keyValueStore());org.apache.kafka</e
浏览 0提问于2018-04-24得票数 0
回答已采纳
我正在尝试访问在同一个java程序中创建的inMemoryStore。org.apache.kafka.common.serialization.Serdes;import org.apache.kafka.streams.StreamsBuilder;import
浏览 0提问于2019-07-12得票数 0
<String, String, KeyValueStore<Bytes, byte[]>>as("asset-master-store"));
是否有一种以编程方式访问此全局KTable的支持全局状态存储的方法
浏览 1提问于2022-04-25得票数 0
我正在访问一个状态存储来查询它，并且不得不用一个try/catch块包装store()语句来重试它，因为有时我会得到这个异常： at org.apache.kafka.streams.state.interna
浏览 2提问于2018-08-25得票数 3
回答已采纳
1回答
import org.apache.kafka.streams._import org.apache.kafka.streams</e
浏览 1提问于2018-07-25得票数 1
我使用Spring Cloud Streams，配置如下： spring: # configure kafka binder brokers: ${spring.kafka.bootstrap-servers}configuration.auto.offset.reset: latest
# kafka</e
浏览 19提问于2019-05-09得票数 1
回答已采纳
我正在迁移一个Kafka实现，它使用纯Kafka来使用spring，因为它包含在一个spring引导应用程序中。所有的工作都很好--流，GlobalKTable，分支--我所有的分支都工作得很好，但是我很难整合一个ReadOnlyKeyValueStore。基于spring文档(这里： ) --如果您需要直接执行一些KafkaStreams操作，可以使用StreamsBuilderFactoryBean.getKafkaStreams()访问该内部基于此，我尝试将其合并到我的示例中，如下所示：
@Bean(n
浏览 0提问于2021-10-21得票数 0
回答已采纳
我试图使用Kafka流从流创建GlobalKTable，并在调用streams.start()时获得异常。org.apache.kafka.streams.errors.StreamsException:遇到了与任何全局状态存储没有关联的主题分区。我的代码是：private final StoreQueryParameters<ReadOnlyKeyValueStore<LocalDate<Loc
浏览 4提问于2020-11-19得票数 2
回答已采纳
然后我有一个带有以下代码的第二命令行应用程序(App2)，它试图将这个KTable作为一个状态存储(ReadOnlyKeyValueStore)来访问，并访问它。); RUNNING
Exception in thread "main"
浏览 18提问于2017-08-30得票数 3
1回答
我正在尝试了解GlobalKtable在kafka中是如何工作的，为此，我尝试编写示例代码。.withKeySerde(stringSerde)
val view: ReadOnlyKeyValueStore[String, abc] = strea
浏览 1提问于2020-08-21得票数 0
readOnlyKeyValueStore = waitUntilStoreIsQueryable("mystore", QueryableStoreTypes.:239) [kafka-streams-2.3.0.jar:?]kafka-streams-2.3.0.jar:?]:250) ~[kafka-streams-2.3.0.jar:?][kafka-streams-2.3.0.jar:?]
浏览 0提问于2019-07-25得票数 2
回答已采纳
1回答
我试图与Kafka流一起工作，我创建了以下拓扑：后来，我像这样启动了流：public KafkaFlowHistor
浏览 2提问于2018-11-29得票数 2
回答已采纳
1回答
我有一个Kafka流转换器，它的功能类似于窗口:它将状态累加到transform()中的状态存储中，然后在punctuate()期间将其转发到输出主题中，状态存储主题分区键与输入主题相同。在punctuate()期间，我希望每个StreamThread只迭代自己的状态存储分区，以尽量减少从支持的kafka主题中读取的数据量。但是我唯一能得到的迭代器就是通过在整个状态
浏览 2提问于2018-04-16得票数 3
回答已采纳
;import org.apache.kafka.streams.kstream.Grouped;import org.apache.kafka.streams.kstream.KTable;
import org.apache.kafka.s
浏览 0提问于2021-03-05得票数 1
云服务器
ICP备案
云直播
即时通信 IM
对象存储
腾讯云开发者
