Kafka 流 - 禁用更改日志中的读取状态

Question

我使用 Kafka Streams 创建了一个应用程序，并对我的输入主题进行了一些聚合。

现在，当应用程序启动时，它需要几分钟的时间才能从 kafka 更新日志中重现其状态（状态目录在启动之间不持久）。

我想禁止在启动时读取更改日志，这意味着它将从头开始。可能吗？

Answer 1

您可以通过 Materialized#withLoggingDisabled() 禁用更改日志记录。

所有有状态运算符（例如，aggregate()、join()）都接受可选的 Materialized 参数。