minor changes

microsoft · Feb 28, 2024 · de1d36a · de1d36a
1 parent 10a9eab
commit de1d36a
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/src/main/java/com/azure/cosmos/kafka/connect/source/CosmosDBSourceTask.java b/src/main/java/com/azure/cosmos/kafka/connect/source/CosmosDBSourceTask.java
@@ -132,11 +132,11 @@ public List<SourceRecord> poll() throws InterruptedException {
             List<String> recordDetails =
                 records
                     .stream()
-                    .map(sourceRecord -> String.format("key %s, offset %s", sourceRecord.key(), sourceRecord.sourceOffset()))
+                    .map(sourceRecord -> String.format("[key %s - offset %s]", sourceRecord.key(), sourceRecord.sourceOffset()))
                     .collect(Collectors.toList());
 
             logger.debug(
-                "Worker {}, sending docs {}",
+                "Worker {}, sending {} documents",
                 this.config.getWorkerName(),
                 recordDetails
             );