- html - 出于某种原因,IE8 对我的 Sass 文件中继承的 html5 CSS 不友好?
- JMeter 在响应断言中使用 span 标签的问题
- html - 在 :hover and :active? 上具有不同效果的 CSS 动画
- html - 相对于居中的 html 内容固定的 CSS 重复背景?
在 kafka 流中定义拓扑时,可以添加全局状态存储。它将需要一个源主题以及一个 ProcessorSupplier
.
处理器接收记录并且可以在将它们添加到存储之前理论上转换它们。但是在恢复的情况下,记录直接从源主题(更改日志)插入到全局状态存储中,跳过在处理器中完成的最终转换。
+-------------+ +-------------+ +---------------+
| | | | | global |
|source topic -------------> processor +--------------> state |
|(changelog) | | | | store |
+-------------+ +-------------+ +---------------+
| ^
| |
+---------------------------------------------------------+
record directly inserted during restoration
NOTE: you should not use the Processor to insert transformed records into the global state store. This store uses the source topic as changelog and during restore will insert records directly from the source. This ProcessorNode should be used to keep the StateStore up-to-date.
最佳答案
是的,这是一个很奇怪的小捕获 22,但是文档是正确的。全局状态存储的处理器不得对记录执行任何操作,而是将它们保存到存储中。
AFAIK,这不是一个哲学问题,只是一个实际问题。原因只是您观察到的行为...... Streams 将输入主题视为存储的更改日志主题,因此在恢复期间绕过处理器(以及反序列化)。
状态恢复绕过任何处理的原因是更改日志中的数据通常与存储中的数据相同,因此对其进行任何新操作实际上都是错误的。另外,将字节从网络中取出并将它们批量写入状态存储中会更有效。我说“通常”是因为在这种情况下,输入主题与普通的更改日志主题并不完全一样,因为它在存储放置期间不会收到其写入。
对于它的值(value),我也很难理解用例。看起来,我们应该:
to(my-global-changelog)
来近似它。制造“变更日志”主题。然后,您将创建全局存储以从您的
my-global-changelog
中读取数据。而不是输入。
关于java - 用于添加全局存储的 Kafka 流用例,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/59029964/
我最近购买了《C 编程语言》并尝试了 Ex 1-8这是代码 #include #include #include /* * */ int main() { int nl,nt,nb;
早上好!我有一个变量“var”,可能为 0。我检查该变量是否为空,如果不是,我将该变量保存在 php session 中,然后调用另一个页面。在这个新页面中,我检查我创建的 session 是否为空,
我正在努力完成 Learn Python the Hard Way ex.25,但我无法理解某些事情。这是脚本: def break_words(stuff): """this functio
我是一名优秀的程序员,十分优秀!