diff --git a/src/test/java/com/snowflake/kafka/connector/internal/streaming/TopicPartitionChannelIT.java b/src/test/java/com/snowflake/kafka/connector/internal/streaming/TopicPartitionChannelIT.java
index e2b92e59d..5effc5397 100644
--- a/src/test/java/com/snowflake/kafka/connector/internal/streaming/TopicPartitionChannelIT.java
+++ b/src/test/java/com/snowflake/kafka/connector/internal/streaming/TopicPartitionChannelIT.java
@@ -544,7 +544,8 @@ public void testMissingOffsetRecordIngestionWithSchematization() throws Exceptio
 
     // verify offset and table size
     // fails here, offset returned is 0:
-    // "Fetched offsetToken for channelName:TESTDB_KAFKA.KAFKA_TEST.KAFKA_CONNECTOR_TEST_TABLE_1637117689234532997.TEST_CONNECTOR_KAFKA_CONNECTOR_TEST_TABLE_1637117689234532997_0, offset:0"
+    // "Fetched offsetToken for
+    // channelName:TESTDB_KAFKA.KAFKA_TEST.KAFKA_CONNECTOR_TEST_TABLE_1637117689234532997.TEST_CONNECTOR_KAFKA_CONNECTOR_TEST_TABLE_1637117689234532997_0, offset:0"
     TestUtils.assertWithRetry(
         () -> service.getOffset(new TopicPartition(topic, PARTITION)) == expectedOffset, 20, 5);
     assert expectedNumRecords == TestUtils.tableSize(testTableName)