We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent c0c7a23 commit f51bf15Copy full SHA for f51bf15
1 file changed
kafka-base/kafka-base-sink/src/main/java/com/dtstack/flink/sql/sink/kafka/table/KafkaSinkTableInfo.java
@@ -41,7 +41,7 @@ public class KafkaSinkTableInfo extends TargetTableInfo {
41
42
public static final String TYPE_KEY = "type";
43
44
- public static final String ENABLE_KEY_PARTITION_KEY = "enableKeyPartition";
+ public static final String ENABLE_KEY_PARTITION_KEY = "enableKeyPartitions";
45
46
public static final String PARTITION_KEY = "partitionKeys";
47
0 commit comments