使用 Spring Cloud Stream 和 Apache Kafka Streams 进行流处理。第六部分 - 状态存储和交互式查询
Part 1 - 编程模型 Part 2 - 编程模型(续) Part 3 - 数据反序列化和序列化 Part 4 - 错误处理 Part 5 - 应用程序定制
在本部分(本系列的第六部分,也是最后一部分),我们将深入研究 Spring Cloud Stream Kafka Streams Binder 如何支持 Kafka Streams 中的状态存储和交互式查询。
命名状态存储
当应用程序需要维护状态时,Kafka Streams 允许您将该状态信息具体化为一个命名状态存储。Kafka Streams 中有多种操作需要跟踪状态,例如 count
、aggregate
、reduce
、各种 windowing
操作等。在大多数情况下,Kafka Streams 使用一个名为 RocksDB 的特殊数据库来维护这个状态存储(除非您明确更改…)