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)
