Details
-
Bug
-
Status: Resolved
-
Major
-
Resolution: Fixed
-
None
Description
Currently in StoreChangelogReader we are calling consumer.position() when logging as well as setting starting offset right after seekingToBeginning, which will incur a blocking round trip with offset request. We should consider batching those in a single round trip for all partitions that needs to seek to beginning (i.e. needs to reset offset).
Attachments
Issue Links
- is duplicated by
-
KAFKA-4221 KafkaConsumer Fetcher can send ListOffsets requests in parallel when initializing position
- Resolved
- links to