Zhen Ye 31a609c21d

fix: kafka should auto reset the offset from earliest to read (#45237) ...

issue: #44172, #45210, #44851

kafka will auto reset the offset to "latest" if the offset is
Out-of-range. the recovery of milvus wal cannot read any message from
that. So once the offset is out-of-range, kafka should read from eariest
to read the latest uncleared data.


https://kafka.apache.org/documentation/#consumerconfigs_auto.offset.reset

Signed-off-by: chyezh <chyezh@outlook.com>

2025-11-03 21:07:33 +08:00

..

builder.go

fix: kafka should auto reset the offset from earliest to read (#45237)

2025-11-03 21:07:33 +08:00

kafka_test.go

feat: Add CDC support (#44124)

2025-09-16 16:32:01 +08:00

message_id_test.go

feat: Add CDC support (#44124)

2025-09-16 16:32:01 +08:00

message_id.go

feat: Add CDC support (#44124)

2025-09-16 16:32:01 +08:00

opener.go

enhance: add walimpls access mode options (#40591)

2025-03-14 10:58:11 +08:00

scanner.go

enhance: Use v2 package name for pkg module (#39990)

2025-02-22 23:15:58 +08:00

wal.go

feat: Add CDC support (#44124)

2025-09-16 16:32:01 +08:00