【问题标题】:Kafka Streams: Count of rows in storeKafka Streams:存储中的行数
【发布时间】:2018-06-06 18:00:41
【问题描述】:

我需要获取存储中的行数,存储在低级处理器 API 中维护。我看到方法“approximateNumEntries()”可以提供此存储中键值映射的近似计数。您能否澄清一下准确度的百分比,这意味着如果商店中有 100 行,我们会得到 95 作为近似计数,或者有时会低于 50?只是想了解影响计数准确性的因素。

注意:假设流应用程序使用单个主题并在单个实例上运行。商店正在通过低级处理器 API 访问,不确定默认情况下是否应用了任何缓存。提交频率保持默认。

【问题讨论】:

    标签: apache-kafka apache-kafka-streams


    【解决方案1】:

    这取决于商店。如果您使用默认的 RocksDB 存储,该方法会在内部从 RocksDB 中返回 "rocksdb.estimate-num-keys"(参见 https://github.com/facebook/rocksdb/wiki/RocksDB-FAQ)——不确定错误范围是什么。

    对于内存存储,在当前实现(当前版本 1.1)中计数实际上是准确的。

    【讨论】:

      猜你喜欢
      • 1970-01-01
      • 2019-07-14
      • 1970-01-01
      • 2023-03-23
      • 2019-07-03
      • 1970-01-01
      • 2017-06-08
      • 2018-10-24
      • 2021-01-04
      相关资源
      最近更新 更多