diff --git a/tests/test_apps/kafkaimporter/client/kafkaimporter/KafkaImportBenchmark.java b/tests/test_apps/kafkaimporter/client/kafkaimporter/KafkaImportBenchmark.java
index <HASH>..<HASH> 100644
--- a/tests/test_apps/kafkaimporter/client/kafkaimporter/KafkaImportBenchmark.java
+++ b/tests/test_apps/kafkaimporter/client/kafkaimporter/KafkaImportBenchmark.java
@@ -365,10 +365,18 @@ public class KafkaImportBenchmark {
         long importRowCount = MatchChecks.getImportRowCount(client);
         boolean testResult = true;
 
+        // so counts that might help debugging....
+        log.info("mirrorRows: " + mirrorRows);
+        log.info("importRows: " + importRows);
+        log.info("importRowCount: " + importRowCount);
+        if (config.useexport) {
+            log.info("exportRowCount: " + exportRowCount);
+        }
+
         if (config.useexport) {
             log.info("Total rows exported: " + finalInsertCount);
             log.info("Unmatched Rows remaining in the export Mirror Table: " + mirrorRows);
-            log.info("Unmatched Rows received from Kafka to Import Table (duplicate rows): " + importRowCount);
+            log.info("Unmatched Rows received from Kafka to Import Table (duplicate rows): " + importRows);
 
             if (mirrorRows != 0) {
                 log.error(mirrorRows + " Rows are missing from the import stream, failing test");
ENG-<I>, release <I>.x: straightening out some mix ups