Updated version to 0.1.8 (#58)

* Updated version to 0.1.8
singlestore-labs · Oct 11, 2024 · 10230f3 · 10230f3
1 parent ca4384f
commit 10230f3
Show file tree

Hide file tree

Showing 3 changed files with 18 additions and 11 deletions.
diff --git a/README.md b/README.md
@@ -39,7 +39,7 @@ in specific columns.
 ### Installation
 
 * Download
-  the [SingleStore connector for Debezium plugin archive](https://github.com/singlestore-labs/singlestore-debezium-connector/releases/download/v0.1.7/singlestore-debezium-connector-0.1.7-plugin.tar.gz).
+  the [SingleStore connector for Debezium plugin archive](https://github.com/singlestore-labs/singlestore-debezium-connector/releases/download/v0.1.8/singlestore-debezium-connector-0.1.7-plugin.tar.gz).
 * Extract the archive to a directory.
 * Add the directory from the previous step to Kafka Connect’s plugin path.
   Set the `plugin.path` property in the `connect-distributed.properties` file.
@@ -232,7 +232,7 @@ operation that inserts data in the `t` table:
          "a":33
       },
       "source":{
-         "version":"0.1.7",
+         "version":"0.1.8",
          "connector":"singlestore",
          "name":"singlestore",
          "ts_ms":1706197043473,
@@ -267,7 +267,7 @@ as the preceding create event.
          "a":22
       },
       "source":{
-         "version":"0.1.7",
+         "version":"0.1.8",
          "connector":"singlestore",
          "name":"singlestore",
          "ts_ms":1706197446500,
@@ -309,7 +309,7 @@ update event examples.
       "before":null,
       "after":null,
       "source":{
-         "version":"0.1.7",
+         "version":"0.1.8",
          "connector":"singlestore",
          "name":"singlestore",
          "ts_ms":1706197665407,

diff --git a/pom.xml b/pom.xml
@@ -407,11 +407,11 @@
     <developerConnection>
       scm:git:[email protected]:singlestore-labs/singlestore-debezium-connector.git
     </developerConnection>
-    <tag>singlestore-debezium-connector-0.1.7</tag>
+    <tag>singlestore-debezium-connector-0.1.8</tag>
     <url>git://[email protected]:singlestore-labs/singlestore-debezium-connector.git</url>
   </scm>
 
   <url>https://github.com/singlestore-labs/singlestore-debezium-connector</url>
 
-  <version>0.1.7</version>
+  <version>0.1.8</version>
 </project>
diff --git a/src/test/java/com/singlestore/debezium/StreamingIT.java b/src/test/java/com/singlestore/debezium/StreamingIT.java
@@ -173,7 +173,7 @@ public void populatesSourceInfo() throws SQLException, InterruptedException {
         SourceRecord record = records.get(0);
 
         Struct source = (Struct) ((Struct) record.value()).get("source");
-        assertEquals(source.get("version"), "0.1.7");
+        assertEquals(source.get("version"), "0.1.8");
         assertEquals(source.get("connector"), "singlestore");
         assertEquals(source.get("name"), "singlestore_topic");
         assertNotNull(source.get("ts_ms"));
@@ -528,8 +528,11 @@ public void testPKInRowstore() throws Exception {
       try (SingleStoreConnection conn = new SingleStoreConnection(
           defaultJdbcConnectionConfigWithTable("pkInRowstore"))) {
         Configuration config = defaultJdbcConfigWithTable("pkInRowstore");
-        config = config.edit().withDefault(SingleStoreConnectorConfig.COLUMN_INCLUDE_LIST,
-            "db.pkInRowstore.a,db.pkInRowstore.c").build();
+        config = config.edit()
+            .withDefault(SingleStoreConnectorConfig.COLUMN_INCLUDE_LIST,
+                "db.pkInRowstore.a,db.pkInRowstore.c")
+            .withDefault("tombstones.on.delete", "false")
+            .build();
         conn.execute("SNAPSHOT DATABASE " + TEST_DATABASE + ";");
         start(SingleStoreConnector.class, config);
         assertConnectorIsRunning();
@@ -577,8 +580,12 @@ public void testPKInColumnstore() throws Exception {
       try (SingleStoreConnection conn = new SingleStoreConnection(
           defaultJdbcConnectionConfigWithTable("pkInColumnstore"))) {
         Configuration config = defaultJdbcConfigWithTable("pkInColumnstore");
-        config = config.edit().withDefault(SingleStoreConnectorConfig.COLUMN_INCLUDE_LIST,
-            "db.pkInColumnstore.a,db.pkInColumnstore.c").build();
+        config = config.edit()
+            .withDefault(SingleStoreConnectorConfig.COLUMN_INCLUDE_LIST,
+                "db.pkInColumnstore.a,db.pkInColumnstore.c")
+            .withDefault("tombstones.on.delete", "false")
+            .build();
+
         conn.execute("SNAPSHOT DATABASE " + TEST_DATABASE + ";");
         start(SingleStoreConnector.class, config);
         assertConnectorIsRunning();