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

[oalsafi]

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 <omars...@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