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

Joining a new instance sometimes does not cause rebalancing

    XMLWordPrintableJSON

    Details

    • Type: Bug
    • Status: Resolved
    • Priority: Major
    • Resolution: Not A Problem
    • Affects Version/s: None
    • Fix Version/s: None
    • Component/s: streams
    • Labels:
      None

      Description

      See attached log. The application is in a REBALANCING state. The second instance joins a bit after the first instance (~250ms). The group coordinator says it is going to rebalance but nothing happens. The first instance gets all partitions (2). The application transitions to RUNNING.

      See attached test, which starts one client and then starts another about 250ms later. This seems to consistently repro the issue for me.

      This is blocking my work on KAFKA-8755, so I'm inclined to pick it up

        Attachments

        1. StandbyTaskTest.java
          7 kB
          Chris Pettitt
        2. fail.log
          147 kB
          Chris Pettitt

          Activity

            People

            • Assignee:
              cpettitt-confluent Chris Pettitt
              Reporter:
              cpettitt-confluent Chris Pettitt
            • Votes:
              0 Vote for this issue
              Watchers:
              5 Start watching this issue

              Dates

              • Created:
                Updated:
                Resolved: