diff --git a/clients/src/main/java/org/apache/kafka/clients/consumer/MockConsumer.java b/clients/src/main/java/org/apache/kafka/clients/consumer/MockConsumer.java index 7b268fe0f49..303f8e5f1dd 100644 --- a/clients/src/main/java/org/apache/kafka/clients/consumer/MockConsumer.java +++ b/clients/src/main/java/org/apache/kafka/clients/consumer/MockConsumer.java @@ -335,7 +335,7 @@ public class MockConsumer implements Consumer { * @param maxPollRecords the max.poll.records. */ public synchronized void setMaxPollRecords(long maxPollRecords) { - if (this.maxPollRecords < 1) { + if (maxPollRecords < 1) { throw new IllegalArgumentException("MaxPollRecords must be strictly superior to 0"); } this.maxPollRecords = maxPollRecords;