build: fix flaky test

eclipse-edc · Nov 13, 2023 · 086f02b · 086f02b
1 parent 0d6086d
commit 086f02b
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 3 deletions.
diff --git a/...a-plane-kafka/src/main/java/org/eclipse/edc/dataplane/kafka/pipeline/KafkaDataSource.java b/...a-plane-kafka/src/main/java/org/eclipse/edc/dataplane/kafka/pipeline/KafkaDataSource.java
@@ -176,10 +176,11 @@ public boolean hasNext() {
 
         @Override
         public ConsumerRecords<String, byte[]> next() {
-            var records = consumer.poll(Duration.ZERO);
-            while (active.get() && records.isEmpty()) {
+            ConsumerRecords<String, byte[]> records;
+            do {
                 records = consumer.poll(pollDuration);
-            }
+            } while (active.get() && records.isEmpty());
+
             return records;
         }
 

diff --git a/...unner/src/test/java/org/eclipse/edc/test/e2e/participant/EndToEndTransferParticipant.java b/...unner/src/test/java/org/eclipse/edc/test/e2e/participant/EndToEndTransferParticipant.java
@@ -239,6 +239,7 @@ public Map<String, String> dataPlaneConfiguration() {
                 put("edc.keystore", resourceAbsolutePath("certs/cert.pfx"));
                 put("edc.keystore.password", "123456");
                 put("edc.dataplane.token.validation.endpoint", controlPlaneControl + "/token");
+                put("edc.dataplane.http.sink.partition.size", "1");
             }
         };
     }