如何截断 KTable

How to truncate a KTable

我有一个使用 KTable 的 kafka 流应用程序。我的应用有运行一段时间，因此 KTable 已经建立。

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

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

谢谢

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

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