Ensure we're not missing any records

Author: blootsvoets

kafka-connect-rest-source/src/main/java/org/radarbase/connect/rest/RestSourceTask.java

@@ -74,6 +74,7 @@ public List<SourceRecord> poll() throws InterruptedException {
       }
 
       requests = requestGenerator.requests()
+          .sequential()
           .filter(RestRequest::isStillValid)
           .peek(r -> {
             logger.info("Requesting {}", r.getRequest().url());
@@ -84,7 +85,7 @@ public List<SourceRecord> poll() throws InterruptedException {
           .filter(Objects::nonNull)
           .map(s -> s.collect(Collectors.toList()))
           .filter(l -> !l.isEmpty())
-          .findAny()
+          .findFirst()
           .orElse(Collections.emptyList());
     } while (requests.isEmpty());