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

getListOffsetsCalls doesn't update node in case of leader change

    XMLWordPrintableJSON

Details

    • Bug
    • Status: Resolved
    • Critical
    • Resolution: Fixed
    • None
    • 2.5.0
    • admin
    • None

    Description

      As seen here:
      https://github.com/apache/kafka/blob/trunk/clients/src/main/java/org/apache/kafka/clients/admin/KafkaAdminClient.java#L3810

      In handling the response in the `listOffsets` call, if there are errors in the topic partition that require a metadata refresh, it simply passes the call object as `this`. This produces incorrect behavior if there was a leader change, because the call object never gets its leader node updated. This will result in a tight loop of list offsets being called to the same old leader and not resulting in offsets, even though the metadata was correctly updated.

      Attachments

        Issue Links

          Activity

            People

              skaundinya Sanjana Kaundinya
              skaundinya Sanjana Kaundinya
              Jason Gustafson Jason Gustafson
              Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: