Kafka Streams - 提交与 Rocks DB 删除的同步

Question

在低级处理器API中，我想在相应的值转发到下游后立即从存储中删除一个键。在重新平衡或提交失败的情况下，对存储执行的删除会自动回滚还是永久删除？如果稍后，有没有办法同步商店删除与提交。上述行为是否会因商店启用缓存与未启用缓存而有所不同？

Answer 1

该行为独立于缓存，如果您 运行 和 "at-least-once" 保证存储不会回滚。

如果您需要更严格的保证，您可以启用 "exactly-once" 处理，以提供与您要求的商店的同步。