[jira] [Created] (KAFKA-8880) Augment Consumer.committed(partition) to allow multiple partitions

[Guozhang Wang (Jira)]

Guozhang Wang created KAFKA-8880:
------------------------------------

             Summary: Augment Consumer.committed(partition) to allow multiple 
partitions
                 Key: KAFKA-8880
                 URL: https://issues.apache.org/jira/browse/KAFKA-8880
             Project: Kafka
          Issue Type: Improvement
          Components: consumer
            Reporter: Guozhang Wang


We've observed that many usage of the consumer.committed calls are made for not 
only one partition, but for a batch of partitions. On the other hand, the 
OffsetFetchRequest protocol actually allows for multiple partitions within one 
request.

I'd propose we add an overloaded function of KafkaConsumer that takes 

{code}
Map<TopicPartition, OffsetAndMetadata> committed(Collection<TopicPartition> 
partitions, final Duration timeout)
{code}

And then deprecate the existing function that only takes on partition.



--
This message was sent by Atlassian Jira
(v8.3.2#803003)