[ https://issues.apache.org/jira/browse/KAFKA-8880?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Guozhang Wang resolved KAFKA-8880. ---------------------------------- Fix Version/s: 2.4.0 Assignee: Guozhang Wang Resolution: Fixed > 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 > Assignee: Guozhang Wang > Priority: Major > Labels: needs-kip, newbie++ > Fix For: 2.4.0 > > > 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.4#803005)