[ https://issues.apache.org/jira/browse/KAFKA-4937?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Damian Guy reassigned KAFKA-4937: --------------------------------- Assignee: Damian Guy > 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 > Assignee: Damian Guy > Labels: newbie++, performance > > 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)