You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@paimon.apache.org by lz...@apache.org on 2023/07/25 10:19:10 UTC
[incubator-paimon] branch master updated: [doc] kafka Database Sync, Fix multiple topic parameter delimiter (#1650)
This is an automated email from the ASF dual-hosted git repository.
lzljs3620320 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-paimon.git
The following commit(s) were added to refs/heads/master by this push:
new a91e9ce3a [doc] kafka Database Sync, Fix multiple topic parameter delimiter (#1650)
a91e9ce3a is described below
commit a91e9ce3aa46f9bb68e42b57df07cc793cadd9d2
Author: hekaifei <48...@users.noreply.github.com>
AuthorDate: Tue Jul 25 18:19:06 2023 +0800
[doc] kafka Database Sync, Fix multiple topic parameter delimiter (#1650)
---
docs/content/how-to/cdc-ingestion.md | 2 +-
.../paimon/flink/action/cdc/kafka/KafkaSyncDatabaseActionFactory.java | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
diff --git a/docs/content/how-to/cdc-ingestion.md b/docs/content/how-to/cdc-ingestion.md
index c3bf9270d..57d3e06a4 100644
--- a/docs/content/how-to/cdc-ingestion.md
+++ b/docs/content/how-to/cdc-ingestion.md
@@ -341,7 +341,7 @@ Synchronization from multiple Kafka topics to Paimon database.
--warehouse hdfs:///path/to/warehouse \
--database test_db \
--kafka-conf properties.bootstrap.servers=127.0.0.1:9020 \
- --kafka-conf topic=order,logistic_order,user \
+ --kafka-conf topic=order\;logistic_order\;user \
--kafka-conf properties.group.id=123456 \
--kafka-conf value.format=canal-json \
--catalog-conf metastore=hive \
diff --git a/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/kafka/KafkaSyncDatabaseActionFactory.java b/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/kafka/KafkaSyncDatabaseActionFactory.java
index 3af9599ac..2e115e9c1 100644
--- a/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/kafka/KafkaSyncDatabaseActionFactory.java
+++ b/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/kafka/KafkaSyncDatabaseActionFactory.java
@@ -127,7 +127,7 @@ public class KafkaSyncDatabaseActionFactory implements ActionFactory {
+ " --warehouse hdfs:///path/to/warehouse \\\n"
+ " --database test_db \\\n"
+ " --kafka-conf properties.bootstrap.servers=127.0.0.1:9020 \\\n"
- + " --kafka-conf topic=order,logistic,user \\\n"
+ + " --kafka-conf topic=order\\;logistic\\;user \\\n"
+ " --kafka-conf properties.group.id=123456 \\\n"
+ " --kafka-conf value.format=canal-json \\\n"
+ " --catalog-conf metastore=hive \\\n"