1
0

[MINOR] fix typo,'seprarated' corrected to 'separated' (#3789)

This commit is contained in:
Jimmy.Zhou
2021-10-16 04:26:16 +08:00
committed by GitHub
parent 2c370cbae0
commit 9aa7cfb802

View File

@@ -87,7 +87,7 @@ public class KafkaConnectUtils {
/** /**
* Extract the record fields. * Extract the record fields.
* @param keyGenerator key generator Instance of the keygenerator. * @param keyGenerator key generator Instance of the keygenerator.
* @return Returns the record key columns seprarated by comma. * @return Returns the record key columns separated by comma.
*/ */
public static String getRecordKeyColumns(KeyGenerator keyGenerator) { public static String getRecordKeyColumns(KeyGenerator keyGenerator) {
return String.join(",", keyGenerator.getRecordKeyFieldNames()); return String.join(",", keyGenerator.getRecordKeyFieldNames());
@@ -99,7 +99,7 @@ public class KafkaConnectUtils {
* *
* @param keyGenerator key generator Instance of the keygenerator. * @param keyGenerator key generator Instance of the keygenerator.
* @param typedProperties properties from the config. * @param typedProperties properties from the config.
* @return partition columns Returns the partition columns seprarated by comma. * @return partition columns Returns the partition columns separated by comma.
*/ */
public static String getPartitionColumns(KeyGenerator keyGenerator, TypedProperties typedProperties) { public static String getPartitionColumns(KeyGenerator keyGenerator, TypedProperties typedProperties) {