From b1707c395d22d228a9fd9e3b0edfb657789fa77b Mon Sep 17 00:00:00 2001
From: Jiri Pechanec <jpechane@redhat.com>
Date: Fri, 9 Nov 2018 06:38:55 +0100
Subject: [PATCH] DBZ-970 Correct plging name for wal2json_streaming decoder

---
 .../connector/postgresql/PostgresConnectorConfig.java        | 5 +++++
 1 file changed, 5 insertions(+)

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 9d4cae13a..04c3334f5 100644
--- 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
@@ -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