Skip to content

Commit 3afd8cc

Browse files
authored
fix: Correct identifier for upsert-kafka-safe connector (#307)
1 parent 9fbfd7a commit 3afd8cc

1 file changed

Lines changed: 1 addition & 1 deletion

File tree

connectors/kafka-safe-connector/src/main/java/org/apache/flink/streaming/connectors/kafka/table/SafeUpsertKafkaDynamicTableFactory.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -85,7 +85,7 @@
8585
public class SafeUpsertKafkaDynamicTableFactory
8686
implements DynamicTableSourceFactory, DynamicTableSinkFactory {
8787

88-
public static final String IDENTIFIER = "upsert-kafka";
88+
public static final String IDENTIFIER = "upsert-kafka-safe";
8989

9090
@Override
9191
public String factoryIdentifier() {

0 commit comments

Comments
 (0)