Uploaded image for project: 'Kafka'
  1. Kafka
  2. KAFKA-8880

Augment Consumer.committed(partition) to allow multiple partitions

    XMLWordPrintableJSON

Details

    • Improvement
    • Status: Resolved
    • Major
    • Resolution: Fixed
    • None
    • 2.4.0
    • consumer

    Description

      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

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

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

      Attachments

        Activity

          People

            guozhang Guozhang Wang
            guozhang Guozhang Wang
            Votes:
            0 Vote for this issue
            Watchers:
            5 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: