Consumer improvements #2592

dpkp · 2025-04-18T19:09:16Z

KAFKA-5078 - Defer fetch record exception if iterator has already moved across a valid record
KAFKA-5075 - Defer consumer fetcher exception if fetch position has already increased
KAFKA-4937 - Batch offset fetches in the Consumer
KAFKA-4547 - Avoid resetting paused partitions to committed offsets

…lready increased

…ed across a valid record

dpkp added 5 commits April 17, 2025 11:26

KAFKA-4547: Avoid resetting paused partitions to committed offsets

76cc5d9

KAFKA-4937: Batch offset fetches in the Consumer

c5c1072

KAFKA-5075 - Defer consumer fetcher exception if fetch position has a…

8c58e2e

…lready increased

KAFKA-5078 - defer fetch record exception if iterator has already mov…

b9e35e6

…ed across a valid record

Drop unused KafkaClient import from test_fetcher

dc004c3

dpkp merged commit 1b53598 into master Apr 19, 2025
18 checks passed

dpkp deleted the dpkp/consumer-fixups branch April 19, 2025 16:47

Provide feedback