remove unneeded stuff

responsivedev · Sep 27, 2024 · d9136dc · d9136dc
1 parent a2ff43f
commit d9136dc
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 35 deletions.
diff --git a/...a-client-examples/e2e-test/src/main/java/dev/responsive/examples/common/EventSignals.java b/...a-client-examples/e2e-test/src/main/java/dev/responsive/examples/common/EventSignals.java
diff --git a/...client-examples/e2e-test/src/main/java/dev/responsive/examples/e2etest/E2ETestDriver.java b/...client-examples/e2e-test/src/main/java/dev/responsive/examples/e2etest/E2ETestDriver.java
@@ -268,7 +268,7 @@ private void maybeLogConsumed() {
     }
     lastLog = Instant.now();
 
-    EventSignals.logNumConsumedOutputRecords(recordsProcessed);
+    LOG.info("consumed {} records", recordsProcessed);
     LOG.info("by key: {}",
         consumeState.values().stream()
             .map(v -> v.key + ":" + v.recvdCount)