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

AsyncKafkaConsumer will get Invalid Request error when trying to rejoin on fenced/unknown member Id

    XMLWordPrintableJSON

Details

    • Sub-task
    • Status: Resolved
    • Major
    • Resolution: Fixed
    • None
    • 3.8.0
    • None
    • None

    Description

      The consumer will log invalid request error when joining from fenced/unknown member id because we didn't reset the HeartbeatState and we won't send the needed fields (rebalanceTimeoutMs for example) when joining.

      Attachments

        Activity

          People

            phuctran Phuc Hong Tran
            pnee Philip Nee
            Votes:
            0 Vote for this issue
            Watchers:
            3 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: