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