我读到Kafka streams use cases for add global store 这个堆栈流程讨论并了解到全局状态存储在恢复期间跳过处理器。
有什么方法可以强制全局状态存储不跳过处理器。
因为输入主题在处理器内没有任何 key ，所以我们正在构造 key 并将其放入状态存储中。
我看到了许多创建自定义更改日志主题的解决方案，该主题将用作全局状态存储的源主题。
但我想知道如何在使用处理器 API 恢复期间强制全局状态存储运行处理器。
最佳答案
This is currently not supported until https://issues.apache.org/jira/browse/KAFKA-7663 and https://issues.apache.org/jira/browse/KAFKA-8037 are resolved.
关于java - 我们可以在全局状态存储恢复期间调用处理器吗？，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/60617320/