fix counter

src/main/kotlin/BulkProcessor.kt

@@ -81,7 +81,7 @@ class BulkProcessor(private val consumer: Consumer,
                     }
                 }
             } else {
-                if (request.numberOfActions() == recordsInBulk) {
+                if (request.numberOfActions() == recordsCounter) {
                     log.info("Bulk upload {} successful. Indexed {} messages. Commit offsets to Kafka. Any failures are resent for processing.",
                             executionId,
                             request.numberOfActions())
@@ -89,7 +89,7 @@ class BulkProcessor(private val consumer: Consumer,
                     log.warn("Bulk upload {} partially successful. Indexed {} out of {} messages. Commit offsets to Kafka. Any failures are resent for processing.",
                             executionId,
                             request.numberOfActions(),
-                            recordsInBulk)
+                            recordsCounter)
                 }
 
             }