我面临的问题与Kafka流反序列化处理程序
使用logandcontinue后，仍然在重新启动服务器时，每次都会显示损坏的消息。
看起来这个jira问题仍然存在，需要解决以解决您所描述的问题：https://issues.apache.org/jira/browse/KAFKA-6502
不过，只有当您有一系列错误的记录时，才会发生这种情况。一旦你有了好的记录，偏移量就会继续移动。因此，作为一种变通方法，您可能会发送一个不会导致错误的好记录？
相关内容
- 没有找到相关文章
最新更新
- 我的' collate_fn '函数在传递给Trainer函数的collate_fn参数时得到空数据
- 访问documentRoot以外的所有图像，而不是Apache windows
- 如何从React或Javascript中的对象属性中获取值
- Redux工具箱:从切片文件导出一个自定义钩子来访问动作，而不是导出所有的动作，然后再次调用调度? &
- CSS难题:孩子们总是闯入多行
- 贴现率，公式
- 使用 Javascript 的嵌套数组循环生成和排序所有象限中 (0,0) 周围的笛卡尔坐标
- 如何在Windows上添加现有的mysql模式
- 从Google VPS中恢复删除的文件夹
- ffmpeg/映射代码的几个输出
- r语言 - 在部署到shinyapps.io的Shiny应用中使用readClipboard()的问题 &
- 如何适应事件SelectionChange代码在事件计算工作?
- 类型错误：.map 不是一个函数不明白出了什么问题
- 在Rust中定义无限嵌套HashMap
- 为什么有些符号表达式没有简化？
- 如何在aws上自动执行jupyter笔记本?
- form如何对一个已经存在的关系进行插入
- 在特定元素上拆分int数组
- 如何在supervisor中记录所有FATAL进程?
- linux kernel fs/buffer.c 中的函数名称 "brelse" 代表什么？
- 使用lru_cache和__hash__缓存对象实例
- 是否可以在 CQL 中"get records older than N days"？
- 处理Rust中所谓的全局变量
- 如何在Javascript中连接for循环中的字符串
- 非原生Wordpress字段的Wordpress表单提交数据存储
- ADB中未知命令tcip
- 如何编写一个检查输入是否符合语法的程序?
- 如何同时在不同的表中创建和更新数据- Laravel 9
- 如何将类方法作为事件添加到html按钮中
- 验证的最大字符数不能正常工作
热门标签：
javascript python java c# php android html jquery c++ css ios sql mysql arrays asp.net json python-3.x ruby-on-rails .net sql-server django objective-c excel regex ruby linux ajax iphone xml vba spring asp.net-mvc database wordpress string postgresql wpf windows xcode bash git oracle list vb.net multithreading eclipse algorithm macos powershell visual-studio image forms numpy scala function api selenium