FIP-53: Log Scanner Offset Management #4608

Activity

1. pisceslj

   added the

   Task

   issue type on Oct 12, 2026
2. pisceslj commented on Oct 13, 2026

   

   pisceslj

   on Oct 13, 2026

   Last edited by pisceslj

   ContributorAuthor

   More actions

   Subtasks

   • 4625 [server] Add consumer offset table foundations
   • 4665 [rpc] Add consumer offset protocol and error definitions
   • 4714 [server] Add consumer group owner discovery
   • 4849 [server] Implement consumer offset commits
   • xx. Server-side fetch path (handleGetConsumerOffsets, point/prefix lookup, value decoding)
   • xx. Server-side management path (list / delete groups / delete offsets, prefix scan, tombstones)
   • xx. Client-side ConsumerGroupManager skeleton + FindConsumerGroupOwner (owner discovery, retries, rediscovery)
   • xx. Client-side commit path (sync/async commit, callback queue, partial failure handling)
   • xx. Client-side fetch path + auto-commit (committed offset retrieval, caching, periodic commits)
   • xx. LogScanner and MultiTableLogScanner integration (switch manually-assigned consumers to the new path, multi-table shared groupId)
   • xx. Admin API implementation (list/alter/delete offsets and groups)
   • xx. LogScannerITCase (end-to-end: starting offsets, auto-commit, restart recovery, multi-table)
   • xx. ConsumerGroupManagerFailoverITCase (immediate serving after leader switch, owner rediscovery, no data loss)