From de1d36ab27a4c83e3c123b7be584d3cce93758fc Mon Sep 17 00:00:00 2001
From: annie-mac <xinlian@microsoft.com>
Date: Tue, 27 Feb 2024 21:55:13 -0800
Subject: [PATCH] minor changes

---
 .../azure/cosmos/kafka/connect/source/CosmosDBSourceTask.java | 4 ++--
 1 file changed, 2 insertions(+), 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
index 1b24a9c0..9259bf79 100644
--- 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
             );