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