Uploaded image for project: 'Kafka'
  1. Kafka
  2. KAFKA-14246 Update threading model for Consumer
  3. KAFKA-15651

Investigate auto commit guarantees during Consumer.assign()

    XMLWordPrintableJSON

Details

    Description

      In the assign() method implementation, both KafkaConsumer and PrototypeAsyncConsumer commit offsets asynchronously. Is this intentional? junrao asks in a recent PR review:

      Do we guarantee that the new owner of the unsubscribed partitions could pick up the latest committed offset?

      Let's confirm whether the asynchronous approach is acceptable and correct. If it is, great, let's enhance the documentation to briefly explain why. If it is not, let's correct the behavior if it's within the API semantic expectations.

      Attachments

        Activity

          People

            kirktrue Kirk True
            kirktrue Kirk True
            Votes:
            0 Vote for this issue
            Watchers:
            3 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: