Address comments.

Author: lvyanquan

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-kafka/src/main/java/org/apache/flink/cdc/connectors/kafka/utils/KafkaSinkUtils.java

@@ -41,7 +41,7 @@ public static Map<Selectors, String> parseSelectorsToTopicMap(String mappingRule
             String[] selectorsAndTopic = mapping.split(DELIMITER_SELECTOR_TOPIC);
             Preconditions.checkArgument(
                     selectorsAndTopic.length == 2,
-                    "Please check you configuration of "
+                    "Please check your configuration of "
                             + KafkaDataSinkOptions.SINK_TABLE_ID_TO_TOPIC_MAPPING);
             Selectors selectors =
                     new Selectors.SelectorsBuilder().includeTables(selectorsAndTopic[0]).build();

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-kafka/src/test/java/org/apache/flink/cdc/connectors/kafka/sink/KafkaDataSinkITCase.java

@@ -324,8 +324,7 @@ void testCanalJsonFormat() throws Exception {
 
         final List<ConsumerRecord<byte[], byte[]>> collectedRecords =
                 drainAllRecordsFromTopic(topic, false, 0);
-        final long recordsCount = 5;
-        assertThat(recordsCount).isEqualTo(collectedRecords.size());
+        assertThat(collectedRecords).hasSize(5);
         for (ConsumerRecord<byte[], byte[]> consumerRecord : collectedRecords) {
             assertThat(
                             consumerRecord