[camel-examples] branch master updated: Change Debezium configurations

[oa...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

oalsafi pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel-examples.git


The following commit(s) were added to refs/heads/master by this push:
     new 90c286f  Change Debezium configurations
90c286f is described below

commit 90c286fc2afb83235c045742aa2b54bcb4cb4228
Author: Omar Al-Safi <om...@gmail.com>
AuthorDate: Wed Jan 6 11:34:00 2021 +0100

    Change Debezium configurations
---
 .../eventhubs/blob/DebeziumMySqlConsumerToAzureEventHubs.java         | 4 ++--
 .../src/main/resources/application.properties                         | 4 ++--
 .../apache/camel/example/debezium/DebeziumMySqlConsumerToKinesis.java | 4 ++--
 .../camel-example-debezium/src/main/resources/application.properties  | 4 ++--
 4 files changed, 8 insertions(+), 8 deletions(-)

diff --git a/examples/camel-example-debezium-eventhubs-blob/src/main/java/org/apache/camel/example/debezium/eventhubs/blob/DebeziumMySqlConsumerToAzureEventHubs.java b/examples/camel-example-debezium-eventhubs-blob/src/main/java/org/apache/camel/example/debezium/eventhubs/blob/DebeziumMySqlConsumerToAzureEventHubs.java
index 97b35b6..32861d4 100644
--- a/examples/camel-example-debezium-eventhubs-blob/src/main/java/org/apache/camel/example/debezium/eventhubs/blob/DebeziumMySqlConsumerToAzureEventHubs.java
+++ b/examples/camel-example-debezium-eventhubs-blob/src/main/java/org/apache/camel/example/debezium/eventhubs/blob/DebeziumMySqlConsumerToAzureEventHubs.java
@@ -58,8 +58,8 @@ public final class DebeziumMySqlConsumerToAzureEventHubs {
                         + "&databasePassword={{debezium.mysql.databasePassword}}"
                         + "&databaseServerName={{debezium.mysql.databaseServerName}}"
                         + "&databaseHistoryFileFilename={{debezium.mysql.databaseHistoryFileName}}"
-                        + "&databaseWhitelist={{debezium.mysql.databaseWhitelist}}"
-                        + "&tableWhitelist={{debezium.mysql.tableWhitelist}}"
+                        + "&databaseIncludeList={{debezium.mysql.databaseIncludeList}}"
+                        + "&tableIncludeList={{debezium.mysql.tableIncludeList}}"
                         + "&offsetStorageFileName={{debezium.mysql.offsetStorageFileName}}")
                         .routeId("FromDebeziumMySql")
                         // We will need to prepare the data for Azure EventHubs Therefore, we will hash the key to make sure our record land on the same partition
diff --git a/examples/camel-example-debezium-eventhubs-blob/src/main/resources/application.properties b/examples/camel-example-debezium-eventhubs-blob/src/main/resources/application.properties
index 7ee6582..3510e2c 100644
--- a/examples/camel-example-debezium-eventhubs-blob/src/main/resources/application.properties
+++ b/examples/camel-example-debezium-eventhubs-blob/src/main/resources/application.properties
@@ -22,8 +22,8 @@ debezium.mysql.databaseUser = debezium
 debezium.mysql.databasePassword = dbz
 debezium.mysql.databaseServerName = debezium-connector-mysql-01
 debezium.mysql.databaseHistoryFileName = dbhistory-01.data
-debezium.mysql.databaseWhitelist = inventory
-debezium.mysql.tableWhitelist = inventory.products
+debezium.mysql.databaseIncludeList = inventory
+debezium.mysql.tableIncludeList = inventory.products
 debezium.mysql.offsetStorageFileName = offset-01.data
 
 eventhubs.connectionString = {{generated_connection_string}}
diff --git a/examples/camel-example-debezium/src/main/java/org/apache/camel/example/debezium/DebeziumMySqlConsumerToKinesis.java b/examples/camel-example-debezium/src/main/java/org/apache/camel/example/debezium/DebeziumMySqlConsumerToKinesis.java
index 841bad7..068a559 100644
--- a/examples/camel-example-debezium/src/main/java/org/apache/camel/example/debezium/DebeziumMySqlConsumerToKinesis.java
+++ b/examples/camel-example-debezium/src/main/java/org/apache/camel/example/debezium/DebeziumMySqlConsumerToKinesis.java
@@ -58,8 +58,8 @@ public final class DebeziumMySqlConsumerToKinesis {
                         + "&databasePassword={{debezium.mysql.databasePassword}}"
                         + "&databaseServerName={{debezium.mysql.databaseServerName}}"
                         + "&databaseHistoryFileFilename={{debezium.mysql.databaseHistoryFileName}}"
-                        + "&databaseWhitelist={{debezium.mysql.databaseWhitelist}}"
-                        + "&tableWhitelist={{debezium.mysql.tableWhitelist}}"
+                        + "&databaseIncludeList={{debezium.mysql.databaseIncludeList}}"
+                        + "&tableIncludeList={{debezium.mysql.tableIncludeList}}"
                         + "&offsetStorageFileName={{debezium.mysql.offsetStorageFileName}}")
                         .routeId("FromDebeziumMySql")
                         // We will need to prepare the data for Kinesis, however we need to mention here is that Kinesis is bit different from Kafka in terms
diff --git a/examples/camel-example-debezium/src/main/resources/application.properties b/examples/camel-example-debezium/src/main/resources/application.properties
index 75ef43d..bf0a3e9 100644
--- a/examples/camel-example-debezium/src/main/resources/application.properties
+++ b/examples/camel-example-debezium/src/main/resources/application.properties
@@ -23,9 +23,9 @@ debezium.mysql.databaseUser = debezium
 debezium.mysql.databasePassword = dbz
 debezium.mysql.databaseServerName = debezium-connector-mysql-01
 debezium.mysql.databaseHistoryFileName = dbhistory-01.data
-debezium.mysql.databaseWhitelist = inventory
+debezium.mysql.databaseIncludeList = inventory
 
-debezium.mysql.tableWhitelist = inventory.products
+debezium.mysql.tableIncludeList = inventory.products
 
 debezium.mysql.offsetStorageFileName = offset-01.data