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

Mock consumer should behave consistent with actual consumer

    XMLWordPrintableJSON

Details

    Description

      Right now in MockConsumer we shall return illegal state exception when the buffered records are not able to find corresponding assigned partitions. This is not the case for KafkaConsumer where we shall just not return those data during `poll()` call. This inconsistent behavior should be fixed.

      Note that if we are going to take this fix, the full unit tests need to be executed to make sure no regression is introduced, as some tests are potentially depending on the current MockConsumer behavior.

      Attachments

        Issue Links

          Activity

            People

              arafsheikh Sheikh Araf
              bchen225242 Boyang Chen
              Votes:
              1 Vote for this issue
              Watchers:
              7 Start watching this issue

              Dates

                Created:
                Updated: