我使用kafka流创建了一个应用程序,并对输入主题进行了聚合。现在,当应用程序启动时,它需要几分钟的时间从kafka changelog复制它的状态(state dir在启动之间不是持久的)。我想在启动时禁用从changelog读取,这意味着它将从头开始。有可能吗?
wgx48brx1#
您可以通过禁用更改日志记录 Materialized#withLoggingDisabled() .所有有状态运算符(例如, aggregate() , join() )接受可选的 Materialized 参数。
Materialized#withLoggingDisabled()
aggregate()
join()
Materialized
1条答案
按热度按时间wgx48brx1#
您可以通过禁用更改日志记录
Materialized#withLoggingDisabled()
.所有有状态运算符(例如,
aggregate()
,join()
)接受可选的Materialized
参数。