[
https://issues.apache.org/jira/browse/KAFKA-8880?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16923822#comment-16923822
]
ASF GitHub Bot commented on KAFKA-8880:
---------------------------------------
guozhangwang commented on pull request #7304: KAFKA-8880: Add overloaded
function of Consumer.committed [WIP]
URL: https://github.com/apache/kafka/pull/7304
KIP pending.
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test coverage and CI build status
- [ ] Verify documentation (including upgrade notes)
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
> 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
> Priority: Major
> Labels: needs-kip, newbie++
>
> 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)
