routine load 执行一段时间后,出现:
ReasonOfStateChanged: ErrorReason{code=errCode = 104, msg='be 10004 abort task with reason: fetch failed due to requested offset not available on the broker: Broker: Offset out of range
routine load 执行一段时间后,出现:
ReasonOfStateChanged: ErrorReason{code=errCode = 104, msg='be 10004 abort task with reason: fetch failed due to requested offset not available on the broker: Broker: Offset out of range
排查方式:
查看kafka端对应的topic 目前最小的offset ,对比show routine load 的progress记录的offset 是不是小于kafka topic 的offset,如果小于则就会出现上述问题
解决方法