禁用从changelog读取状态

byqmnocz  于 2021-06-07  发布在  Kafka
关注(0)|答案(1)|浏览(290)

我使用kafka流创建了一个应用程序,并对输入主题进行了聚合。
现在,当应用程序启动时,它需要几分钟的时间从kafka changelog复制它的状态(state dir在启动之间不是持久的)。
我想在启动时禁用从changelog读取,这意味着它将从头开始。有可能吗?

wgx48brx

wgx48brx1#

您可以通过禁用更改日志记录 Materialized#withLoggingDisabled() .
所有有状态运算符(例如, aggregate() , join() )接受可选的 Materialized 参数。

相关问题