- html - 出于某种原因,IE8 对我的 Sass 文件中继承的 html5 CSS 不友好?
- JMeter 在响应断言中使用 span 标签的问题
- html - 在 :hover and :active? 上具有不同效果的 CSS 动画
- html - 相对于居中的 html 内容固定的 CSS 重复背景?
我无法理解如何将数据保存到 globalKTable。我尝试使用
在 Java 中创建 GlobalKTable
GlobalKTable globalTable = builder.globalTable(inputTopic, Materialized.>as("global-store"));
在此之后我无法找到任何直接将数据存储到此 GlobalKTable 的示例。它在任何地方都与连接或流一起使用。
最佳答案
由于每个 Stream 应用程序实例加载整个 GlobalKTable
数据,它默认禁用记录到 changelog
主题,并且 GlobalKTable
使用输入主题作为恢复过程的更改日志源(以实现容错),因此更改全局存储没有意义,您不能这样做。
您可以使用 ProcessorContext.getStateStore("global-store")
获得对 Processor API 中全局状态的只读访问权限,而无需将存储添加到 Processor
.
实现此目的的一种方法是将要进行的更新推送到 inputTopic
,以便它更新所有应用程序实例中的每个 GlobalKTable。
关于java - 将数据存储到 GlobalKTable,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/60741656/
我无法理解如何将数据保存到 globalKTable。我尝试使用 在 Java 中创建 GlobalKTable GlobalKTable globalTable = builder.globalTa
我无法理解如何将数据保存到 globalKTable。我尝试使用 在 Java 中创建 GlobalKTable GlobalKTable globalTable = builder.globalTa
我们有一个带有单个分区的压缩主题,并向其中添加了一个新分区。 我们没有对现有数据进行重新分区 - 这意味着在添加新分区之前加载的事件仍在分区 0 中。新事件按照标准策略存储,正如预期的那样:具有相同键
使用 Kafka Stream,我总是使用以下代码从引用紧凑主题初始化我的商店: builder.globalTable(kafkaTopic, Materialized.as("storeMerch
我有一个主题,在商店中被读取为 GlobalKTable 和 Materialized。问题是,如果我更新该主题的 key ,然后从存储中读取,一段时间(~0.5秒)我会得到旧值。 此问题的原因可能是
我想 ReKey 一个 GlobalKTable(可能是在初始化它的时候,因为我相信它们一旦创建就只读)。 这可能吗? 我在 Spring/Java Kafka Streams 应用程序中处理了两个主
我用来创建 GlobalKTable 的话题非常活跃。在 KStream-GlobalKTable join 的文档中我读了 The GlobalKTable is fully bootstrappe
我有一个输入流: KStream inputStream = ... 我想以输出到 GlobalKTable 的方式进行操作(过滤然后聚合)然后我可以使用: KeyValueIterator = st
我有一个输入流: KStream inputStream = ... 我想以输出到 GlobalKTable 的方式进行操作(过滤然后聚合)然后我可以使用: KeyValueIterator = st
我的目标是拥有一个数据流 (KStream),其 ID 为 Integer,值为 String,在本例中,我们将在值中存储某人的姓名。然后我还将使用 GlobalKTable 创建一个查找表,该表将术
我有一个基于 Spring 云流的 Kafka Streams 应用程序,我在其中将 Global KTable 绑定(bind)到 Compact 主题。当我将墓碑记录推送到主题(具有空值的非空键)
我了解两者之间的区别,但似乎我仍然使用 KTable作为“默认”,不知道何时更喜欢 GlobalKTable . 请分享您的经验,什么时候有GlobalKTable是必须的,为什么不使用它等等。 最佳
为什么全局表不能在kafka中启用日志记录? 代码: if (loggingEnabled) { throw new TopologyException("StateStore " + sto
在 Kafka Stream 库中,我想知道 KTable 和 GlobalKTable 之间的区别。 同样在 KStream 类中,还有两个方法 leftJoin()和 outerJoin() .这
我是一名优秀的程序员,十分优秀!