我有一个卡夫卡流应用程序,利用KTable。我的应用程序运行了一段时间,所以KTable已经建立起来了。
如何截断KTable (假设我的应用程序能够处理表的重构)?
停止我的应用程序并从变更主题中删除数据是正确的方式吗?这似乎有点复杂,我觉得应该有一个更简单的方法。
谢谢
发布于 2018-10-09 13:09:22
如果您想从头开始重新创建KTable,可以使用应用程序重置工具。这可能是你的一种选择。
应用程序重置工具将删除为应用程序ID创建的所有变更量和重新分区主题,因此在新运行时,您将获得新的KTable和状态存储。
https://cwiki.apache.org/confluence/display/KAFKA/Kafka+Streams+Application+Reset+Tool
https://stackoverflow.com/questions/52711741
复制相似问题