diff --git a/debezium-connector-postgres/src/main/java/io/debezium/connector/postgresql/PostgresConnectorConfig.java b/debezium-connector-postgres/src/main/java/io/debezium/connector/postgresql/PostgresConnectorConfig.java index a8273a86a26..7af5c1a9399 100755 --- a/debezium-connector-postgres/src/main/java/io/debezium/connector/postgresql/PostgresConnectorConfig.java +++ b/debezium-connector-postgres/src/main/java/io/debezium/connector/postgresql/PostgresConnectorConfig.java @@ -540,15 +540,14 @@ public static SchemaRefreshMode parse(String value) { public static final Field PLUGIN_NAME = Field.create("plugin.name") .withDisplayName("Plugin") .withGroup(Field.createGroupEntry(Field.Group.CONNECTION_ADVANCED_REPLICATION, 0)) - .withEnum(LogicalDecoder.class, LogicalDecoder.DECODERBUFS) + .withEnum(LogicalDecoder.class, LogicalDecoder.YBOUTPUT) .withWidth(Width.MEDIUM) .withImportance(Importance.MEDIUM) .withDescription("The name of the Postgres logical decoding plugin installed on the server. " + - "Supported values are '" + LogicalDecoder.DECODERBUFS.getValue() - + "' and '" + LogicalDecoder.PGOUTPUT.getValue() + "Supported values are '" + LogicalDecoder.PGOUTPUT.getValue() + "' and '" + LogicalDecoder.YBOUTPUT.getValue() + "'. " + - "Defaults to '" + LogicalDecoder.DECODERBUFS.getValue() + "'."); + "Defaults to '" + LogicalDecoder.YBOUTPUT.getValue() + "'."); public static final Field SLOT_NAME = Field.create("slot.name") .withDisplayName("Slot")