Adding NoSuchElementException

bf2fc6cc711aee1a0c2a · Aug 22, 2022 · 4250431 · 4250431
1 parent 9f40e25
commit 4250431
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/kafka-admin/src/main/java/org/bf2/admin/kafka/admin/RecordOperations.java b/kafka-admin/src/main/java/org/bf2/admin/kafka/admin/RecordOperations.java
@@ -133,11 +133,12 @@ public boolean hasNext() {
                 }
 
                 @Override
-                public ConsumerRecords<byte[], byte[]> next() throws NoSuchElementException {
+                public ConsumerRecords<byte[], byte[]> next() {
                     var records = consumer.poll(Duration.ofMillis(100));
                     int pollSize = records.count();
                     emptyPoll = pollSize == 0;
                     recordsConsumed.addAndGet(pollSize);
+                    if (emptyPoll) { throw new NoSuchElementException(); }
                     if (log.isTraceEnabled()) {
                         log.tracef("next() consumed records: %d; total %s", pollSize, recordsConsumed.get());
                     }