如果我为 Samza 中的 RocksDB 表指定更改日志支持。是否有配置将异步写入时间更新到更改日志?我想把它缩短到更短的时间。我在Config 参考中看不到任何内容。
我想要的场景是在桥接旧 JMS 连接后从流中写入更改日志。这个遗留连接提供了部分更新,我想将部分更新合并到更完整的消息中,在 samza 流应用程序中构建这些消息的缓存,并将它们写到更改日志中。
如果我使用配置的变更日志,stores.store-name.changelog
那么它将写入变更日志,最终我对 Samze API 表所做的更改。但对我的需求不够快,所以想配置最大等待时间以传播到变更日志。
或者,似乎withSideInputs
每次都使用引导我的表,然后使用sendTo
会更快地更新,我也可以保持LocalStore
读写缓存,并且始终将更改日志作为黄金来源。
我希望更改日志也能快速写入的原因是因为其他应用程序正在从该更改日志中读取。