autoformatting

snowflakedb · Nov 6, 2023 · 50f8150 · 50f8150
1 parent f13727e
commit 50f8150
Showing 1 changed file with 2 additions and 1 deletion.
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
@@ -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)