Uploaded image for project: 'Managed Service - Streams'
  1. Managed Service - Streams
  2. MGDSTRM-9017

[track upstream KAFKA-14010] alterISR request won't retry when receiving retriable error

XMLWordPrintable

    • Icon: Bug Bug
    • Resolution: Done
    • Icon: Major Major
    • None
    • None
    • kafka
    • None
    • False
    • None
    • False
    • No
    • ---
    • ---
    • MK - Sprint 221

      WHAT

      When submitting the AlterIsr request, we register a future listener to handle the response here. When receiving retriable error, we expected the AlterIsr request will get retried. And then, we'll re-submit the request again.

      However, before the future listener got called, we didn't clear the `unsentIsrUpdates`, which causes we failed to "enqueue" the request because we thought there's an in-flight request. We use "try/finally" to make sure the unsentIsrUpdates got cleared (here), but it happened "after" we retry the request

      Although the AlterIsr request will get sent next time when the follower sent next fetch request to the leader, we still need to fix this issue to make sure the AlterIsr request is sent successfully as we expected.

      WHY

      Isr might not get updated successfully

      HOW

      <Suggestions for how this may be solved.> [Optional]

      DONE

      KAFKA-14010 is merged into upstream trunk and 3.2 branches 

            lukchen@redhat.com Luke Chen
            lukchen@redhat.com Luke Chen
            Kafka Integrations
            Votes:
            0 Vote for this issue
            Watchers:
            1 Start watching this issue

              Created:
              Updated:
              Resolved: