Return null with empty results.

valdar · Sep 7, 2020 · 2edcfc0 · 2edcfc0
1 parent bb8d2a3
commit 2edcfc0
Showing 1 changed file with 1 addition and 4 deletions.
diff --git a/core/src/main/java/org/apache/camel/kafkaconnector/CamelSourceTask.java b/core/src/main/java/org/apache/camel/kafkaconnector/CamelSourceTask.java
@@ -155,17 +155,14 @@ public synchronized List<SourceRecord> poll() {
                     records.add(record);
                 }
                 collectedRecords++;
-            } else {
-                break;
             }
         }
 
         if (records.isEmpty()) {
-            return Collections.EMPTY_LIST;
+            return null;
         } else {
             return records;
         }
-
     }
 
     @Override