From 1f3e42ac37d91354422635a58259983c8b529156 Mon Sep 17 00:00:00 2001
From: rajan <rdhabalia@apache.org>
Date: Tue, 22 Dec 2020 21:54:34 -0800
Subject: [PATCH] [pulsar-io] upgrade debezium version

fix compilation
---
 pom.xml                                                      | 2 +-
 .../org/apache/pulsar/io/debezium/PulsarDatabaseHistory.java | 5 +++++
 2 files changed, 6 insertions(+), 1 deletion(-)

diff --git a/pom.xml b/pom.xml
index 0348c0fe3dda3..839e260edaccf 100644
--- a/pom.xml
+++ b/pom.xml
@@ -144,7 +144,7 @@ flexible messaging model and an intuitive client API.</description>
     <presto.version>332</presto.version>
     <scala.binary.version>2.11</scala.binary.version>
     <scala-library.version>2.11.12</scala-library.version>
-    <debezium.version>1.0.0.Final</debezium.version>
+    <debezium.version>1.3.1.Final</debezium.version>
     <jsonwebtoken.version>0.11.1</jsonwebtoken.version>
     <opencensus.version>0.18.0</opencensus.version>
     <hbase.version>2.3.0</hbase.version>
diff --git a/pulsar-io/debezium/core/src/main/java/org/apache/pulsar/io/debezium/PulsarDatabaseHistory.java b/pulsar-io/debezium/core/src/main/java/org/apache/pulsar/io/debezium/PulsarDatabaseHistory.java
index c3d95a7a6dedf..6524e329b38bf 100644
--- a/pulsar-io/debezium/core/src/main/java/org/apache/pulsar/io/debezium/PulsarDatabaseHistory.java
+++ b/pulsar-io/debezium/core/src/main/java/org/apache/pulsar/io/debezium/PulsarDatabaseHistory.java
@@ -257,4 +257,9 @@ public String toString() {
         }
         return "Pulsar topic";
     }
+
+    @Override
+    public boolean storageExists() {
+        return true;
+    }
 }