独家记忆shine 2022-03-11 14:05 采纳率: 42.9%
浏览 104
已结题

kafka提交报错,希望能得到解决

一:背景
手动poll kafka消息,并且手动提交; 运行的时候,偶尔(频次比较低)会出现如下错误:
org.apache.kafka.clients.consumer.RetriableCommitFailedException: Offset commit failed with a retriable exception. You should retry committing offsets.
The underlying error was: null 。

二:主要是这段代码
consumer.commitAsync(new OffsetCommitCallback() {
@Override
public void onComplete(Map<TopicPartition, OffsetAndMetadata> offsets,
Exception exception) {
if (exception != null) {
LOG.error("【kafka数据迁移】kafka数据commit失败,offset:{},error:{}",offsets,exception);
}
}
});

  • 写回答

2条回答 默认 最新

  • 丨封尘绝念斩丨 2022-03-11 15:32
    关注
    获得1.25元问题酬金

    将session.timeout.ms 设置大些可以解决问题

    评论

报告相同问题?

问题事件

  • 系统已结题 3月19日
  • 创建了问题 3月11日

悬赏问题

  • ¥15 如何在3D高斯飞溅的渲染的场景中获得一个可控的旋转物体
  • ¥88 实在没有想法,需要个思路
  • ¥15 MATLAB报错输入参数太多
  • ¥15 python中合并修改日期相同的CSV文件并按照修改日期的名字命名文件
  • ¥15 有赏,i卡绘世画不出
  • ¥15 如何用stata画出文献中常见的安慰剂检验图
  • ¥15 c语言链表结构体数据插入
  • ¥40 使用MATLAB解答线性代数问题
  • ¥15 COCOS的问题COCOS的问题
  • ¥15 FPGA-SRIO初始化失败