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

Replica fetcher thread need to back off upon getting errors on partitions

    XMLWordPrintableJSON

Details

    • Bug
    • Status: Resolved
    • Major
    • Resolution: Duplicate
    • None
    • None
    • None

    Description

      ReplicaFetcherThread's handlePartitionsWithErrors() function needs to be implemented (currently it is an empty function) such that upon getting errors on these partitions, the fetcher thread will back off the corresponding simple consumer to retry fetching that partition.

      This can happen when there is leader migration, the replica may get a bit delayed receiving the leader ISR update request before keeping retry fetching the old leader.

      Attachments

        Issue Links

          duplicates

          Improvement - An improvement or enhancement to an existing feature or task. KAFKA-1461 Replica fetcher thread does not implement any back-off behavior

          • Major - Major loss of function.
          • Resolved

          Activity

            People

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

              Dates

                Created:
                Updated:
                Resolved: