A. Sophie Blee-Goldman created KAFKA-12485:
----------------------------------------------
Summary: Speed up Consumer#committed by returning cached offsets
for owned partitions
Key: KAFKA-12485
URL: https://issues.apache.org/jira/browse/KAFKA-12485
Project: Kafka
Issue Type: Improvement
Components: consumer
Reporter: A. Sophie Blee-Goldman
All of the KafkaConsumer#committed APIs will currently make a remote blocking
call to the server to fetch the committed offsets. This is typically used to
reset the offsets after a crash or restart, or to fetch offsets for other
consumers in the group. However some users may wish to invoke this API on
partitions which are currently owned by the Consumer, in which case the remote
call is unnecessary since those offsets should already be known.
We should consider optimizing these APIs to just return the cached offsets in
place of the remote call when passed in only partitions that are currently
owned. This is similar to what we do in Consumer#position, although there we
have a guarantee that the partitions are owned by the Consumer whereas in
#committed we do not
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
