Doris Routine Load重置offset

Viewed 5
2.0

使用Routine Load消费kafka消息时，经常会出现offset过期的情况

[INTERNAL_ERROR]fetch failed due to requested offset not available on the broker: Broker: Offset out of range

如何监控这种情况，或者如何在Routine Load在被自动调起时，将offset进度调整为offset_beginning

1 Answers
  1. 首先得根据导入速度来合理的配置offset的过期时间，比如log.retention.hours、log.retention.bytes
  2. 当前只能手动修改：

image.png

阿渊@SelectDB (没回帖直接加我主页微信)9660
Related Questions
Doris Routine Load重置offset
1 answers
Doris 2.0.15，3FE、6BE（3BE mix角色 3BE computation角色）3个mix角色的BE节点CPU使用率100%
1 answers
我的doris版本为2.0.6 在备份操作时，会导致所以fe节点宕机，这种情况该怎么排查，为什么备份会导致这个问题？
1 answers
Doris Routine Load自动恢复机制
1 answers
doris fe节点变更成高可用配置
1 answers
各位大哥在通过k8s安装doris3.0的时候，有没有遇到cg启动不起来，提示Set max number of open file descriptors to a value greater than 60000.
1 answers