不溜過客 2025-06-07 14:15 采纳率: 98.8%
浏览 1

Kafka报错:Current offset 6 for partition __consumer_offsets-28 is out of range,如何定位与解决?

### Kafka报错:Current offset 6 for partition __consumer_offsets-28 is out of range,如何定位与解决? 此问题通常发生在Kafka消费者尝试从`__consumer_offsets`主题中读取偏移量时,发现指定的偏移量超出范围。可能原因包括:1) 消费者组元数据损坏;2) 主题被清理导致偏移量丢失;3) Kafka版本不兼容。 **定位方法**:检查Kafka日志和`__consumer_offsets`主题的分区数据,确认是否存在偏移量6。使用`kafka-consumer-groups.sh --bootstrap-server --group --describe`命令查看消费者组状态。 **解决办法**:1) 重启消费者以重新提交偏移量;2) 使用`--reset-offsets`重置消费者组偏移量;3) 如果数据完整性受损,重建消费者组或手动修复偏移量;4) 确保Kafka集群和客户端版本一致,并调整`log.retention.hours`避免过早清理。 注意:操作前备份关键数据,避免影响业务运行。
  • 写回答

0条回答 默认 最新

    报告相同问题?

    问题事件

    • 创建了问题 6月7日