apache-kafka - 如何截断 KTable
问题描述
我有一个使用 KTable 的 kafka 流应用程序。我的应用程序已经运行了一段时间,所以 KTable 已经建立起来了。
如何截断 KTable(假设我的应用程序可以处理重建表)?
是否以正确的方式停止我的应用程序并从更改日志主题中删除数据?这似乎有点复杂,我觉得应该有一个更简单的方法。
谢谢
解决方案
KTable
如果您想从头开始重新创建,您可以使用应用程序重置工具。这可能是您的一种选择。
应用程序重置工具将删除为应用程序 ID 创建的所有更改日志和重新分区主题,因此对于新运行,您将获得新的KTable
和状态存储。
https://cwiki.apache.org/confluence/display/KAFKA/Kafka+Streams+Application+Reset+Tool
推荐阅读
- java - 如何使用java检查像“08-Nov-2011”这样的字符串是否是有效日期?
- ruby - 如何修复 Sinatra 在/未定义的局部变量或方法处返回 NameError
- reactjs - 使用 React 和 Ant 设计将轮播的引用传递给打字稿?
- php - 如何使用 PHP 从多个页面访问会话变量
- clang - Clang OpenMP 版本,无法获取最新版本
- php - 当我尝试使用 php 文件时,ffmpeg 显示 null
- mysql - docker-compse.yml spring boot mysql 配置
- javascript - 如何在 jsreport 中包含助手
- excel - 如果在列中发现重复,如何匹配和合并 Google 表格中的行?
- javascript - 使用 JavaScript(Chrome 扩展)将数据填充到 Office 365 Excel 表单中