apache-kafka - 如何截断 KTable

Question

我有一个使用 KTable 的 kafka 流应用程序。我的应用程序已经运行了一段时间，所以 KTable 已经建立起来了。

如何截断 KTable（假设我的应用程序可以处理重建表）？

是否以正确的方式停止我的应用程序并从更改日志主题中删除数据？这似乎有点复杂，我觉得应该有一个更简单的方法。

谢谢

score 3 · Accepted Answer

KTable如果您想从头开始重新创建，您可以使用应用程序重置工具。这可能是您的一种选择。

应用程序重置工具将删除为应用程序 ID 创建的所有更改日志和重新分区主题，因此对于新运行，您将获得新的KTable和状态存储。

1 回答 1