DBZ-4311 Fix wrong include/exclude list option names in examples (deb…

…ezium#186) * DBZ-4311 Fix wrong include/exclude list option names in examples * DBZ-4311 Upgrade examples to debezium 1.7
mellyzarsmwn · Nov 18, 2021 · 9874287 · 9874287
1 parent 2f24fb1
commit 9874287
Show file tree

Hide file tree

Showing 70 changed files with 85 additions and 85 deletions.
diff --git a/apache-pulsar/pom.xml b/apache-pulsar/pom.xml
@@ -13,7 +13,7 @@
         <maven.compiler.target>1.8</maven.compiler.target>
         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
         <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
-        <version.debezium>1.4.0.Final</version.debezium>
+        <version.debezium>1.7.1.Final</version.debezium>
         <pulsar.version>2.1.1-incubating</pulsar.version>
 
     </properties>

diff --git a/apache-pulsar/src/main/resources/config.properties b/apache-pulsar/src/main/resources/config.properties
@@ -8,7 +8,7 @@ database.port=5432
 database.user=postgres
 database.password=postgres
 database.dbname=postgres
-database.include=inventory
+database.include.list=inventory
 plugin.name=wal2json
 database.server.name=test
 

diff --git a/auditlog/README.md b/auditlog/README.md
@@ -22,7 +22,7 @@ $ mvn clean package
 ```
 
 ```console
-$ export DEBEZIUM_VERSION=1.4
+$ export DEBEZIUM_VERSION=1.7
 $ docker-compose up --build
 ```
 

diff --git a/auditlog/register-postgres.json b/auditlog/register-postgres.json
@@ -7,5 +7,5 @@
     "database.password": "postgrespw",
     "database.dbname" : "vegetablesdb",
     "database.server.name": "dbserver1",
-    "table.include": "inventory.vegetable,inventory.transaction_context_data"
+    "table.include.list": "inventory.vegetable,inventory.transaction_context_data"
 }
diff --git a/.../java/io/debezium/examples/cacheinvalidation/persistence/DatabaseChangeEventListener.java b/.../java/io/debezium/examples/cacheinvalidation/persistence/DatabaseChangeEventListener.java
@@ -75,7 +75,7 @@ public void startEmbeddedEngine(@Observes @Initialized(ApplicationScoped.class)
                 .with("database.password", "postgrespw")
                 .with("database.server.name", "dbserver1")
                 .with("database.dbname", "inventory")
-                .with("database.include", "public")
+                .with("database.include.list", "public")
                 .with(PostgresConnectorConfig.SNAPSHOT_MODE, SnapshotMode.NEVER)
                 .build();
 

diff --git a/camel-component/pom.xml b/camel-component/pom.xml
@@ -26,8 +26,8 @@
         <mysql.init.timeout>30000</mysql.init.timeout>
 
         <version.camel>3.0.1</version.camel>
-        <version.debezium>1.4.0.Final</version.debezium>
-        <version.debezium.tag>1.4</version.debezium.tag>
+        <version.debezium>1.7.1.Final</version.debezium>
+        <version.debezium.tag>1.7</version.debezium.tag>
         <version.postgresql.driver>42.2.9</version.postgresql.driver>
         <version.org.slf4j>1.7.29</version.org.slf4j>
         <version.quarkus>1.2.0.Final</version.quarkus>

diff --git a/camel-kafka-connect/README.md b/camel-kafka-connect/README.md
@@ -25,7 +25,7 @@ The example consists of multiple components:
 Build the CoAP server and start the example by running:
 
 ```
-$ export DEBEZIUM_VERSION=1.4
+$ export DEBEZIUM_VERSION=1.7
 $ mvn clean install
 $ docker-compose up --build
 ```

diff --git a/camel-kafka-connect/source.json b/camel-kafka-connect/source.json
@@ -9,7 +9,7 @@
         "database.password": "postgres",
         "database.dbname" : "postgres",
         "database.server.name": "dbserver1",
-        "schema.include": "inventory",
+        "schema.include.list": "inventory",
         "transforms": "route",
         "transforms.route.type": "org.apache.kafka.connect.transforms.RegexRouter",
         "transforms.route.regex": "([^.]+)\\.([^.]+)\\.([^.]+)",

diff --git a/cloudevents/README.md b/cloudevents/README.md
@@ -5,7 +5,7 @@ This demo automatically deploys the topology of services as defined in the [Debe
 ## Preparations
 
 ```shell
-export DEBEZIUM_VERSION=1.4
+export DEBEZIUM_VERSION=1.7
 mvn clean install -f avro-data-extractor/pom.xml
 docker-compose up --build
 ```

diff --git a/cloudevents/avro-data-extractor/pom.xml b/cloudevents/avro-data-extractor/pom.xml
@@ -22,7 +22,7 @@
 
         <apache.kafka.version>2.0.0</apache.kafka.version>
         <version.quarkus>1.1.1.Final</version.quarkus>
-        <version.debezium>1.4.0.Final</version.debezium>
+        <version.debezium>1.7.1.Final</version.debezium>
     </properties>
 
     <dependencyManagement>

diff --git a/cloudevents/register-postgres-avro-avro.json b/cloudevents/register-postgres-avro-avro.json
@@ -8,7 +8,7 @@
     "database.dbname" : "postgres",
     "database.server.name": "dbserver3",
     "slot.name":"dbserver3",
-    "schema.include": "inventory",
+    "schema.include.list": "inventory",
     "key.converter": "org.apache.kafka.connect.json.JsonConverter",
     "key.converter.schemas.enable": "false",
     "value.converter": "io.debezium.converters.CloudEventsConverter",

diff --git a/cloudevents/register-postgres-json-avro.json b/cloudevents/register-postgres-json-avro.json
@@ -8,7 +8,7 @@
     "database.dbname" : "postgres",
     "database.server.name": "dbserver2",
     "slot.name":"dbserver2",
-    "schema.include": "inventory",
+    "schema.include.list": "inventory",
     "key.converter": "org.apache.kafka.connect.json.JsonConverter",
     "key.converter.schemas.enable": "false",
     "value.converter": "io.debezium.converters.CloudEventsConverter",

diff --git a/cloudevents/register-postgres-json-json.json b/cloudevents/register-postgres-json-json.json
@@ -8,7 +8,7 @@
     "database.dbname" : "postgres",
     "database.server.name": "dbserver1",
     "slot.name":"dbserver1",
-    "schema.include": "inventory",
+    "schema.include.list": "inventory",
     "key.converter": "org.apache.kafka.connect.json.JsonConverter",
     "key.converter.schemas.enable": "false",
     "value.converter": "io.debezium.converters.CloudEventsConverter",

diff --git a/debezium-server-mongo-pubsub/README.md b/debezium-server-mongo-pubsub/README.md
@@ -7,7 +7,7 @@ This demo explains how to deploy [Debezium Server](https://debezium.io/documenta
 **In the terminal:**
 
 ```shell
-export DEBEZIUM_VERSION=1.6
+export DEBEZIUM_VERSION=1.7
 ```
 
 **In GCP:**

diff --git a/debezium-server-mongo-pubsub/mongo-compose.yml b/debezium-server-mongo-pubsub/mongo-compose.yml
@@ -2,7 +2,7 @@ version: "3.4"
 
 services:
   mongodb:
-    image: debezium/example-mongodb:1.6
+    image: debezium/example-mongodb:1.7
     container_name: mongodb
     ports:
       - 27017:27017

diff --git a/debezium-server-name-mapper/README.md b/debezium-server-name-mapper/README.md
@@ -22,7 +22,7 @@ Both Apache Pulsar and the source database are deployed via Docker Compose file.
 From terminal start the source database and the sink system:
 
 ```
-$ export DEBEZIUM_VERSION=1.6
+$ export DEBEZIUM_VERSION=1.7
 $ docker-compose up
 ```
 

diff --git a/debezium-server-name-mapper/pom.xml b/debezium-server-name-mapper/pom.xml
@@ -10,8 +10,8 @@
         <maven.compiler.source>1.8</maven.compiler.source>
         <maven.compiler.target>1.8</maven.compiler.target>
 
-        <version.debezium>1.6.0.Final</version.debezium>
-        <version.debezium.tag>1.6</version.debezium.tag>
+        <version.debezium>1.7.1.Final</version.debezium>
+        <version.debezium.tag>1.7</version.debezium.tag>
         <version.quarkus>2.0.0.Final</version.quarkus>
         <version.jandex>1.1.0</version.jandex>
     </properties>

diff --git a/debezium-server-name-mapper/src/main/resources/application.properties b/debezium-server-name-mapper/src/main/resources/application.properties
@@ -9,7 +9,7 @@ debezium.source.database.user=postgres
 debezium.source.database.password=postgres
 debezium.source.database.dbname=postgres
 debezium.source.database.server.name=tutorial
-debezium.source.schema.include=inventory
+debezium.source.schema.include.list=inventory
 
 # Needed till https://issues.redhat.com/browse/DBZ-2192 is released
 quarkus.index-dependency.pulsar.group-id=io.debezium

diff --git a/distributed-caching/README.md b/distributed-caching/README.md
@@ -23,7 +23,7 @@ $ mvn clean verify
 Setup the necessary environment variables:
 
 ```console
-$ export DEBEZIUM_VERSION=1.4
+$ export DEBEZIUM_VERSION=1.7
 ```
 
 The `DEBEZIUM_VERSION` specifies which version of Debezium artifacts should be used.

diff --git a/distributed-caching/cache-update-service/pom.xml b/distributed-caching/cache-update-service/pom.xml
@@ -66,7 +66,7 @@
     <dependency>
       <groupId>io.debezium</groupId>
       <artifactId>debezium-core</artifactId>
-      <version>1.4.0.Final</version>
+      <version>1.7.1.Final</version>
     </dependency>
     <dependency>
       <groupId>io.quarkus</groupId>

diff --git a/end-to-end-demo/README.md b/end-to-end-demo/README.md
@@ -13,7 +13,7 @@ It does these things:
 
 ## Setup Environment
 
-- export DEBEZIUM_VERSION=1.4
+- export DEBEZIUM_VERSION=1.7
 
 ## Build maven artifacts used by the Docker builds
 

diff --git a/end-to-end-demo/debezium-jdbc/Dockerfile b/end-to-end-demo/debezium-jdbc/Dockerfile
@@ -1,4 +1,4 @@
-ARG DEBEZIUM_VERSION=1.4
+ARG DEBEZIUM_VERSION=1.7
 
 FROM debezium/connect:$DEBEZIUM_VERSION
 

diff --git a/end-to-end-demo/register-hiking-connector-json.json b/end-to-end-demo/register-hiking-connector-json.json
@@ -9,7 +9,7 @@
         "database.password": "dbz",
         "database.server.id": "184055",
         "database.server.name": "dbserver1",
-        "database.include": "inventory",
+        "database.include.list": "inventory",
         "database.history.kafka.bootstrap.servers": "kafka:9092",
         "database.history.kafka.topic": "schema-changes.inventory",
         "transforms": "route",

diff --git a/end-to-end-demo/register-hiking-connector.json b/end-to-end-demo/register-hiking-connector.json
@@ -9,7 +9,7 @@
         "database.password": "dbz",
         "database.server.id": "184054",
         "database.server.name": "dbserver1",
-        "database.include": "inventory",
+        "database.include.list": "inventory",
         "database.history.kafka.bootstrap.servers": "kafka:9092",
         "database.history.kafka.topic": "schema-changes.inventory",
         "transforms": "route",

diff --git a/failover/README.md b/failover/README.md
@@ -19,7 +19,7 @@ The deployment consists of the following components
 
 Start the components and register Debezium to stream changes from the database
 ```
-export DEBEZIUM_VERSION=1.4
+export DEBEZIUM_VERSION=1.7
 docker-compose up --build
 curl -i -X POST -H "Accept:application/json" -H "Content-Type:application/json" http://localhost:8083/connectors/ -d @register-mysql.json
 ```

diff --git a/failover/register-mysql.json b/failover/register-mysql.json
@@ -9,7 +9,7 @@
         "database.password": "dbz",
         "database.server.id": "184054",
         "database.server.name": "dbserver1",
-        "database.include": "inventory",
+        "database.include.list": "inventory",
         "database.history.kafka.bootstrap.servers": "kafka:9092",
         "database.history.kafka.topic": "schema-changes.inventory",
         "gtid.new.channel.position": "earliest"

diff --git a/graphql/README.md b/graphql/README.md
@@ -27,7 +27,7 @@ mvn clean install -f aggregator/pom.xml
 Start Kafka, Kafka Connect, MySQL, event source and aggregator:
 
 ```shell
-export DEBEZIUM_VERSION=1.6
+export DEBEZIUM_VERSION=1.7
 docker-compose up --build
 ```
 

diff --git a/graphql/mysql-source.json b/graphql/mysql-source.json
@@ -10,7 +10,7 @@
         "database.server.id": "184054",
         "database.server.name": "dbserver1",
         "decimal.handling.mode": "string",
-        "table.include": "inventory.orders,inventory.customers",
+        "table.include.list": "inventory.orders,inventory.customers",
         "database.history.kafka.bootstrap.servers": "kafka:9092",
         "database.history.kafka.topic": "schema-changes.inventory"
     }

diff --git a/jpa-aggregations/README.md b/jpa-aggregations/README.md
@@ -15,7 +15,7 @@ How to run:
 cd json-smt-es && mvn clean install && cd ../
 
 # Start the DB, Kafka Connect, Elasticsearch etc.
-export DEBEZIUM_VERSION=1.4
+export DEBEZIUM_VERSION=1.7
 docker-compose up --build
 
 # Register MySQL connector to capture changes from the "aggregates" table

diff --git a/jpa-aggregations/source.json b/jpa-aggregations/source.json
@@ -9,8 +9,8 @@
         "database.password": "dbz",
         "database.server.id": "184054",
         "database.server.name": "dbserver1",
-        "database.include": "inventory",
-        "table.include": ".*aggregates",
+        "database.include.list": "inventory",
+        "table.include.list": ".*aggregates",
         "database.history.kafka.bootstrap.servers": "kafka:9092",
         "database.history.kafka.topic": "schema-changes.inventory",
         "transforms" : "expandjson",

diff --git a/json-logging/README.md b/json-logging/README.md
@@ -13,7 +13,7 @@ The Debezium `connect` image is enriched with the required JAR files for that pu
 Start the components and register Debezium to stream changes from the database:
 
 ```
-$ export DEBEZIUM_VERSION=1.4
+$ export DEBEZIUM_VERSION=1.7
 $ docker-compose up --build
 $ curl -i -X POST -H "Accept:application/json" -H "Content-Type:application/json" http://localhost:8083/connectors/ -d @register-mysql.json
 ```

diff --git a/json-logging/register-mysql.json b/json-logging/register-mysql.json
@@ -9,7 +9,7 @@
         "database.password": "dbz",
         "database.server.id": "184054",
         "database.server.name": "dbserver1",
-        "database.include": "inventory",
+        "database.include.list": "inventory",
         "database.history.kafka.bootstrap.servers": "kafka:9092",
         "database.history.kafka.topic": "schema-changes.inventory"
     }

diff --git a/kinesis/pom.xml b/kinesis/pom.xml
@@ -14,15 +14,15 @@
         <database.port>3306</database.port>
         <database.user>debezium</database.user>
         <database.password>dbz</database.password>
-        <database.include>inventory</database.include>
-        <table.include>inventory.customers</table.include>
+        <database.include.list>inventory</database.include.list>
+        <table.include.list>inventory.customers</table.include.list>
 
         <kinesis.region>eu-central-1</kinesis.region>
 
         <mysql.init.timeout>30000</mysql.init.timeout>
 
-        <version.debezium>1.4.0.Final</version.debezium>
-        <version.debezium.tag>1.4</version.debezium.tag>
+        <version.debezium>1.7.1.Final</version.debezium>
+        <version.debezium.tag>1.7</version.debezium.tag>
         <version.kinesis.client>1.13.3</version.kinesis.client>
         <version.jackson>2.10.0</version.jackson>
         <version.plugin.docker>0.24.0</version.plugin.docker>
@@ -106,12 +106,12 @@
                             <value>${database.password}</value>
                         </systemProperty>
                         <systemProperty>
-                            <key>database.include</key>
-                            <value>${database.include}</value>
+                            <key>database.include.list</key>
+                            <value>${database.include.list}</value>
                         </systemProperty>
                         <systemProperty>
-                            <key>table.include</key>
-                            <value>${table.include}</value>
+                            <key>table.include.list</key>
+                            <value>${table.include.list}</value>
                         </systemProperty>
                         <systemProperty>
                             <key>kinesis.region</key>

diff --git a/ksql/README.md b/ksql/README.md
@@ -4,7 +4,7 @@ This demo accompanies the blog post [Querying Debezium Change Data Events With K
 
 ```shell
 # Start the Kafka, Kafka Connect, KSQL server and CLI etc.
-export DEBEZIUM_VERSION=1.4
+export DEBEZIUM_VERSION=1.7
 docker-compose up
 
 # Start Debezium MySQL connector

diff --git a/ksql/register-mysql.json b/ksql/register-mysql.json
@@ -9,7 +9,7 @@
         "database.password": "dbz",
         "database.server.id": "184055",
         "database.server.name": "dbserver",
-        "database.include": "inventory",
+        "database.include.list": "inventory",
         "database.history.kafka.bootstrap.servers": "kafka:9092",
         "database.history.kafka.topic": "schema-changes.inventory",
         "transforms": "unwrap",

diff --git a/kstreams-fk-join/aggregator/pom.xml b/kstreams-fk-join/aggregator/pom.xml
@@ -46,7 +46,7 @@
     <dependency>
       <groupId>io.debezium</groupId>
       <artifactId>debezium-core</artifactId>
-      <version>1.7.0.Final</version>
+      <version>1.7.1.Final</version>
     </dependency>
     <dependency>
       <groupId>io.quarkus</groupId>

diff --git a/kstreams-fk-join/register-postgres.json b/kstreams-fk-join/register-postgres.json
@@ -7,7 +7,7 @@
     "database.password": "postgres",
     "database.dbname" : "postgres",
     "database.server.name": "dbserver1",
-    "schema.include": "inventory",
+    "schema.include.list": "inventory",
     "decimal.handling.mode" : "string",
     "poll.interval.ms": "100",
     "key.converter": "org.apache.kafka.connect.json.JsonConverter",

diff --git a/kstreams-live-update/README.md b/kstreams-live-update/README.md
@@ -34,7 +34,7 @@ mvn clean install -f aggregator/pom.xml
 Start Kafka, Kafka Connect, MySQL (or Postgres), event source and aggregator:
 
 ```shell
-export DEBEZIUM_VERSION=1.4
+export DEBEZIUM_VERSION=1.7
 
 # For MySQL
 docker-compose -f docker-compose-mysql.yaml up --build

diff --git a/kstreams-live-update/aggregator/pom.xml b/kstreams-live-update/aggregator/pom.xml
@@ -21,7 +21,7 @@
         <version.surefire>2.22.0</version.surefire>
 
         <version.quarkus>1.3.0.Final</version.quarkus>
-        <version.debezium>1.4.0.Final</version.debezium>
+        <version.debezium>1.7.1.Final</version.debezium>
     </properties>
 
     <dependencyManagement>

diff --git a/kstreams-live-update/demo-os.md b/kstreams-live-update/demo-os.md
@@ -68,7 +68,7 @@ cat <<'EOF' > register-mysql-source.json
         "database.server.id": "184055",
         "database.server.name": "dbserver1",
         "decimal.handling.mode" : "string",
-        "table.include": "inventory.orders,inventory.categories",
+        "table.include.list": "inventory.orders,inventory.categories",
         "database.history.kafka.bootstrap.servers": "my-cluster-kafka-bootstrap:9092",
         "database.history.kafka.topic": "schema-changes.inventory"
     }
@@ -211,7 +211,7 @@ oc exec -c kafka -i my-cluster-kafka-0 -- curl -s -w "\n" -X POST \
         "database.server.id": "184055",
         "database.server.name": "dbserver1",
         "decimal.handling.mode" : "string",
-        "table.include": "inventory.orders,inventory.categories",
+        "table.include.list": "inventory.orders,inventory.categories",
         "database.history.kafka.bootstrap.servers": "my-cluster-kafka-bootstrap:9092",
         "database.history.kafka.topic": "schema-changes.inventory"
     }