Kafka Streams：存储中的行数
Kafka Streams: Count of rows in store
我需要获取存储中的行数，存储在低级处理器 API 中维护。我看到 "approximateNumEntries()" 方法可以提供该商店中键值映射的近似计数。您能否澄清一下准确率百分比，这意味着如果商店中有 100 行，我们会得到 95 行作为近似计数，还是有时会低于 50 行？只是想了解影响计数准确性的因素。
注意：假设流应用程序消费单个主题并在单个实例上运行。正在通过低级处理器 API 访问存储，不确定是否默认应用任何缓存。提交频率保持默认。
这取决于商店。如果您使用默认的 RocksDB 存储，RocksDB 内部 returns "rocksdb.estimate-num-keys" 的方法（参见 https://github.com/facebook/rocksdb/wiki/RocksDB-FAQ）——不确定错误范围是什么。
对于内存存储，计数在当前实现（当前版本 1.1）中实际上是准确的。
我需要获取存储中的行数，存储在低级处理器 API 中维护。我看到 "approximateNumEntries()" 方法可以提供该商店中键值映射的近似计数。您能否澄清一下准确率百分比，这意味着如果商店中有 100 行，我们会得到 95 行作为近似计数，还是有时会低于 50 行？只是想了解影响计数准确性的因素。
注意：假设流应用程序消费单个主题并在单个实例上运行。正在通过低级处理器 API 访问存储，不确定是否默认应用任何缓存。提交频率保持默认。
这取决于商店。如果您使用默认的 RocksDB 存储，RocksDB 内部 returns "rocksdb.estimate-num-keys" 的方法（参见 https://github.com/facebook/rocksdb/wiki/RocksDB-FAQ）——不确定错误范围是什么。
对于内存存储，计数在当前实现（当前版本 1.1）中实际上是准确的。