From 17b04ca6a7b99ceae610c6357e1fcf0ebad4f22f Mon Sep 17 00:00:00 2001 From: Joshua Temple Date: Sun, 23 Aug 2026 04:11:56 -0400 Subject: [PATCH] docs(source): align SeekToCursor doc with backend conventions MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit The core doc said 're-delivering from just after it' while Kafka re-delivers the record at the cursor itself (SetOffsets to the cursor's own offset) — gate-found cross-surface inconsistency; wording now matches the adapter and its README. --- source/capability.go | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/source/capability.go b/source/capability.go index 2558a9c..5f58bc9 100644 --- a/source/capability.go +++ b/source/capability.go @@ -49,7 +49,8 @@ type Seekable interface { // SeekToTime repositions delivery to the first message at or after t. SeekToTime(ctx context.Context, t time.Time) error // SeekToCursor repositions delivery to resume from a previously observed - // [Cursor] (re-delivering from just after it, per the backend's convention). + // [Cursor], re-delivering from the cursor's position per the backend's + // convention (Kafka re-delivers the record at the cursor). SeekToCursor(ctx context.Context, c Cursor) error // SeekToStart repositions delivery to the earliest retained message. SeekToStart(ctx context.Context) error