exception - 当处理器抛出未捕获的异常时,Kafka 流应用程序关闭?
问题描述
如主题所述,我怎样才能提交这个偏移量,并在不关闭流应用程序的情况下继续处理?
解决方案
推荐阅读
- haskell - Haskell 如何知道数据类型声明是变量还是命名类型?
- php - PHP:导入具有空单元格/列的 CSV 文件时,列数不匹配
- python - Pandas:确定 2 个时间序列相交的位置和方向
- php - 上传文件,并将文件名插入数据库
- sql-server - Streamreader 循环读取多个日志文件夹 vb.net
- c# - 下载文件损坏,要修复
- xml - 如果子节点包含此文本,则提取属性值
- html - 如何在移动视图中的表格中的单元格元素之间具有相等的间距?
- javascript - 如何从javascript中的选择选项中获取多个值?
- powershell - 批处理文件中的循环迭代缓慢