首页 文章

kafka：提交偏移失败，可重试异常 . 您应该重试提交偏移量

提问于
浏览 次
8

[o.a.k.c.c.i.ConsumerCoordinator] [组使用者组的自动偏移提交失败：提交偏移失败，可重试异常 . 你应该重试提交补偿 . ] []

为什么 Kafka 消费者会出现这种错误？这是什么意思？

我使用的消费者属性是：

fetch.min.bytes:1
enable.auto.commit:true
auto.offset.reset:latest
auto.commit.interval.ms:5000
request.timeout.ms:300000
session.timeout.ms:20000
max.poll.interval.ms:600000
max.poll.records:500
max.partition.fetch.bytes:10485760

出现这种错误的原因是什么？由于这个错误，我猜测消费者现在正在做重复的工作 .

我既不使用 consumer.commitAsync() 或 consumer.commitSync()

java apache-kafka

1 回答

  • 2

    如果它捕获 RetriableException 的实例，则消费者会提供此错误 .

    原因可能是各种各样的：

    • 如果协调员仍在加载组元数据

    • 如果尚未创建组元数据主题

    • 如果发生网络或磁盘损坏，或者在处理请求时发生了与磁盘相关的杂项或与网络相关的IOException

    • 如果服务器在请求完成之前断开连接

    • 如果客户端的元数据已过期

    • 如果给定分区当前没有可用的领导者

    • 如果没有经纪人可以完成请求

    从上面的列表中可以看出，所有这些错误都可能是临时问题，这就是建议重试请求的原因 .

    回复于

相关问题