alexey.rassokhin/tet123
1
0
Fork 0
Code Issues Pull Requests 1 Packages Projects Releases Wiki Activity

DBZ-970 Correct plging name for wal2json_streaming decoder

Browse Source
This commit is contained in:
Jiri Pechanec 2018-11-09 06:38:55 +01:00 committed by Gunnar Morling
parent 83137d0a41
commit b1707c395d
1 changed files with 5 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
debezium-connector-postgres/src/main/java/io/debezium/connector/postgresql/PostgresConnectorConfig.java
View File

@ -301,6 +301,11 @@ public MessageDecoder messageDecoder() {
public MessageDecoder messageDecoder() {
return new StreamingWal2JsonMessageDecoder();
}
@Override
public String getPostgresPluginName() {
return "wal2json";
}
},
WAL2JSON_RDS_STREAMING("wal2json_rds_streaming") {
@Override