(*^_^*)静一静 2022-03-11 14:05 采纳率: 18.8%
浏览 209
已结题

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日