Uploaded image for project: 'Kafka'
  1. Kafka
  2. KAFKA-14048 The Next Generation of the Consumer Rebalance Protocol
  3. KAFKA-15843

Review consumer onPartitionsAssigned called with empty partitions

    XMLWordPrintableJSON

Details

    Description

      Legacy coordinator triggers onPartitionsAssigned with empty assignment (which is not the case when triggering onPartitionsRevoked or Lost). This is the behaviour of the legacy coordinator, and the new consumer implementation maintains the same principle. We should review this to fully understand if it is really needed to call onPartitionsAssigned with empty assignment (or if it should behave consistently with the onRevoke/Lost).

      Note that the consumer integration tests rely on this call to onPartitionsAssigned to #awaitRebalance (AbstractConsumerTest.scala)

      Attachments

        Activity

          People

            lianetm Lianet Magrans
            lianetm Lianet Magrans
            Votes:
            0 Vote for this issue
            Watchers:
            3 Start watching this issue

            Dates

              Created:
              Updated: