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

Idempotent producer: a producerId reset causes undesirable behavior for inflight batches to other partitions

    XMLWordPrintableJSON

Details

    • Bug
    • Status: Open
    • Major
    • Resolution: Unresolved
    • 0.11.0.0
    • None
    • None

    Description

      Currently, if we have to reset the producer id for any reason (for instance if batches to a partition get expired, if we get an OutOfOrderSequenceException, etc) we could cause batches to other -healthy- partitions to fail with a spurious OutOfOrderSequenceException.

      This is detailed in this PR discussion: https://github.com/apache/kafka/pull/3743#discussion_r137907630

      Ideally, we would want all inflight batches to be handled to completion rather than potentially failing them prematurely. Further, since we want to tighten up the semantics of the OutOfOrderSequenceException, at the very least we should raise another exception in this case, because there is no data loss on the broker when the client gives up.

      Attachments

        Activity

          People

            Unassigned Unassigned
            apurva Apurva Mehta
            Votes:
            0 Vote for this issue
            Watchers:
            4 Start watching this issue

            Dates

              Created:
              Updated: