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

Consumer hang in poll method while rebalancing is in progress

    XMLWordPrintableJSON

Details

    • Bug
    • Status: Resolved
    • Major
    • Resolution: Not A Bug
    • 0.10.1.0, 0.10.2.0
    • None
    • core
    • None

    Description

      After moving to Kafka 0.10.2.0, it looks like I'm experiencing a hang in the rebalancing code.

      This is a test case, not (still) production code. It does the following with a single-partition topic and two consumers in the same group:

      1) a topic with one partition is forced to be created (auto-created)
      2) a producer is used to write 10 messages
      3) the first consumer reads all the messages and commits
      4) the second consumer attempts a poll() and hangs indefinitely

      The same issue can't be found with 0.10.0.0.

      See the attached logs at TRACE level. Look for "SERVER HANGS" to see where the hang is found: when this happens, the client keeps failing any hearbeat attempt, as the rebalancing is in progress, and the poll method hangs indefinitely.

      Attachments

        1. Kafka 0.10.2.0 Issue (TRACE) - Server + Client.txt
          871 kB
          Domenico Di Giulio
        2. Kafka 0.10.2.0 Issue (TRACE).txt
          544 kB
          Domenico Di Giulio
        3. KAFKA_5016.java
          7 kB
          Domenico Di Giulio

        Issue Links

          Activity

            People

              vahid Vahid Hashemian
              domenico74 Domenico Di Giulio
              Votes:
              0 Vote for this issue
              Watchers:
              7 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: