diff --git a/kafka-client-examples/e2e-test/src/main/java/dev/responsive/examples/e2etest/E2ETestDriver.java b/kafka-client-examples/e2e-test/src/main/java/dev/responsive/examples/e2etest/E2ETestDriver.java
index 607ca0595..ddf34e22f 100644
--- a/kafka-client-examples/e2e-test/src/main/java/dev/responsive/examples/e2etest/E2ETestDriver.java
+++ b/kafka-client-examples/e2e-test/src/main/java/dev/responsive/examples/e2etest/E2ETestDriver.java
@@ -271,6 +271,7 @@ private void pollOnce() {
   private void maybeFireSetupCompleteSignal() {
     if (!setupCompleteSignalFired && recordsProcessed > 0) {
       LOG.info("Received at least one output record, setup is complete");
+      setupCompleteSignalFired = true;
       Lifecycle.setupComplete(null);
     }
   }