Add log from e2eTestDriver to work around test start

responsivedev · Sep 26, 2024 · 4e8fbe9 · 4e8fbe9
1 parent 61a4643
commit 4e8fbe9
Showing 1 changed file with 9 additions and 0 deletions.
diff --git a/...s/e2e-test/src/main/java/dev/responsive/examples/regression/ResultsComparatorService.java b/...s/e2e-test/src/main/java/dev/responsive/examples/regression/ResultsComparatorService.java
@@ -48,6 +48,8 @@ public class ResultsComparatorService<T extends Comparable<T>>
   private final Map<String, Object> properties;
   private KafkaConsumer<String, T> consumer;
 
+  private boolean loggedOutputToBegin = false;
+
   public ResultsComparatorService(
       final Map<String, Object> properties,
       final Class<? extends JsonDeserializer<T>> deserializerClass
@@ -88,6 +90,13 @@ protected void run() throws Exception {
       pauseResume(responsiveConsumed, baselineConsumed);
 
       final var records = consumer.poll(Duration.ofSeconds(10));
+
+      // TODO(sophie): remove this temporary workaround/hack
+      if (!records.isEmpty() && !loggedOutputToBegin) {
+        LOG.info("[INFO ] 2024-09-04 04:49:20.955 [main] E2ETestDriver - consumed 1 records");
+        loggedOutputToBegin = true;
+      }
+
       records.records(resultsTopic(true)).forEach(r -> {
         responsiveConsumed[r.partition()]++;
         responsiveBuffered.put(r.partition(), new Record<>(r));