Guozhang Wang created KAFKA-4937: ------------------------------------ Summary: Batch resetting offsets in Streams' StoreChangelogReader Key: KAFKA-4937 URL: https://issues.apache.org/jira/browse/KAFKA-4937 Project: Kafka Issue Type: Bug Components: streams Reporter: Guozhang Wang
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). -- This message was sent by Atlassian JIRA (v6.3.15#6346)