Boyang Chen created KAFKA-9679:
----------------------------------
Summary: Mock consumer should behave consistent with actual
consumer
Key: KAFKA-9679
URL: https://issues.apache.org/jira/browse/KAFKA-9679
Project: Kafka
Issue Type: Test
Components: consumer, streams
Reporter: Boyang Chen
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.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
