You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by ur...@apache.org on 2022/12/07 06:10:31 UTC
[pulsar-site] branch main updated: Docs sync done from apache/pulsar (#d22d0be)
This is an automated email from the ASF dual-hosted git repository.
urfree pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/pulsar-site.git
The following commit(s) were added to refs/heads/main by this push:
new dafd3de33ff Docs sync done from apache/pulsar (#d22d0be)
dafd3de33ff is described below
commit dafd3de33ffed75122334e82bc4d1de2ea3a50c4
Author: github-actions[bot] <41...@users.noreply.github.com>
AuthorDate: Wed Dec 7 06:10:27 2022 +0000
Docs sync done from apache/pulsar (#d22d0be)
---
site2/website-next/docs/io-cdc-debezium.md | 4 +---
site2/website-next/docs/io-debezium-source.md | 10 ++++------
2 files changed, 5 insertions(+), 9 deletions(-)
diff --git a/site2/website-next/docs/io-cdc-debezium.md b/site2/website-next/docs/io-cdc-debezium.md
index b9e0d4f9aa8..981fe1926ec 100644
--- a/site2/website-next/docs/io-cdc-debezium.md
+++ b/site2/website-next/docs/io-cdc-debezium.md
@@ -133,7 +133,7 @@ This example shows how to change the data of a MySQL table using the Pulsar Debe
```bash
bin/pulsar-admin source localrun \
--archive connectors/pulsar-io-debezium-mysql-@pulsar:version@.nar \
- --name debezium-mysql-source --destination-topic-name debezium-mysql-topic \
+ --name debezium-mysql-source \
--tenant public \
--namespace default \
--source-config '{"database.hostname": "localhost","database.port": "3306","database.user": "debezium","database.password": "dbz","database.server.id": "184054","database.server.name": "dbserver1","database.whitelist": "inventory","database.history": "org.apache.pulsar.io.debezium.PulsarDatabaseHistory","database.history.pulsar.topic": "history-topic","database.history.pulsar.service.url": "pulsar://127.0.0.1:6650","key.converter": "org.apache.kafka.connect.json.JsonConverter","va [...]
@@ -256,7 +256,6 @@ This example shows how to change the data of a PostgreSQL table using the Pulsar
bin/pulsar-admin source localrun \
--archive connectors/pulsar-io-debezium-postgres-@pulsar:version@.nar \
--name debezium-postgres-source \
- --destination-topic-name debezium-postgres-topic \
--tenant public \
--namespace default \
--source-config '{"database.hostname": "localhost","database.port": "5432","database.user": "postgres","database.password": "postgres","database.dbname": "postgres","database.server.name": "dbserver1","schema.whitelist": "inventory","pulsar.service.url": "pulsar://127.0.0.1:6650"}'
@@ -399,7 +398,6 @@ This example shows how to change the data of a MongoDB table using the Pulsar De
bin/pulsar-admin source localrun \
--archive connectors/pulsar-io-debezium-mongodb-@pulsar:version@.nar \
--name debezium-mongodb-source \
- --destination-topic-name debezium-mongodb-topic \
--tenant public \
--namespace default \
--source-config '{"mongodb.hosts": "rs0/mongodb:27017","mongodb.name": "dbserver1","mongodb.user": "debezium","mongodb.password": "dbz","mongodb.task.id": "1","database.whitelist": "inventory","pulsar.service.url": "pulsar://127.0.0.1:6650"}'
diff --git a/site2/website-next/docs/io-debezium-source.md b/site2/website-next/docs/io-debezium-source.md
index a68dbcb53ab..119a0929e2a 100644
--- a/site2/website-next/docs/io-debezium-source.md
+++ b/site2/website-next/docs/io-debezium-source.md
@@ -170,7 +170,7 @@ This example shows how to change the data of a MySQL table using the Pulsar Debe
```bash
bin/pulsar-admin source localrun \
--archive connectors/pulsar-io-debezium-mysql-@pulsar:version@.nar \
- --name debezium-mysql-source --destination-topic-name debezium-mysql-topic \
+ --name debezium-mysql-source \
--tenant public \
--namespace default \
--source-config '{"database.hostname": "localhost","database.port": "3306","database.user": "debezium","database.password": "dbz","database.server.id": "184054","database.server.name": "dbserver1","database.whitelist": "inventory","database.history": "org.apache.pulsar.io.debezium.PulsarDatabaseHistory","database.history.pulsar.topic": "history-topic","database.history.pulsar.service.url": "pulsar://127.0.0.1:6650","key.converter": "org.apache.kafka.connect.json.JsonConverter","va [...]
@@ -178,7 +178,7 @@ This example shows how to change the data of a MySQL table using the Pulsar Debe
:::note
- Currently, the destination topic (specified by the `destination-topic-name` option ) is a required configuration but it is not used for the Debezium connector to save data. The Debezium connector saves data in the following 4 types of topics:
+ The Debezium connector saves data in the following 4 types of topics:
- One topic named with the database server name (`database.server.name`) for storing the database metadata messages, such as `public/default/database.server.name`.
- One topic (`database.history.pulsar.topic`) for storing the database history information. The connector writes and recovers DDL statements on this topic.
@@ -313,7 +313,6 @@ This example shows how to change the data of a PostgreSQL table using the Pulsar
bin/pulsar-admin source localrun \
--archive connectors/pulsar-io-debezium-postgres-@pulsar:version@.nar \
--name debezium-postgres-source \
- --destination-topic-name debezium-postgres-topic \
--tenant public \
--namespace default \
--source-config '{"database.hostname": "localhost","database.port": "5432","database.user": "postgres","database.password": "changeme","database.dbname": "postgres","database.server.name": "dbserver1","schema.whitelist": "public","table.whitelist": "public.users","pulsar.service.url": "pulsar://127.0.0.1:6650"}'
@@ -321,7 +320,7 @@ This example shows how to change the data of a PostgreSQL table using the Pulsar
:::note
- Currently, the destination topic (specified by the `destination-topic-name` option ) is a required configuration but it is not used for the Debezium connector to save data. The Debezium connector saves data in the following 4 types of topics:
+ The Debezium connector saves data in the following 4 types of topics:
- One topic named with the database server name (`database.server.name`) for storing the database metadata messages, such as `public/default/database.server.name`.
- One topic (`database.history.pulsar.topic`) for storing the database history information. The connector writes and recovers DDL statements on this topic.
@@ -474,7 +473,6 @@ This example shows how to change the data of a MongoDB table using the Pulsar De
bin/pulsar-admin source localrun \
--archive connectors/pulsar-io-debezium-mongodb-@pulsar:version@.nar \
--name debezium-mongodb-source \
- --destination-topic-name debezium-mongodb-topic \
--tenant public \
--namespace default \
--source-config '{"mongodb.hosts": "rs0/mongodb:27017","mongodb.name": "dbserver1","mongodb.user": "debezium","mongodb.password": "dbz","mongodb.task.id": "1","database.whitelist": "inventory","database.history.pulsar.service.url": "pulsar://127.0.0.1:6650"}'
@@ -482,7 +480,7 @@ This example shows how to change the data of a MongoDB table using the Pulsar De
:::note
- Currently, the destination topic (specified by the `destination-topic-name` option ) is a required configuration but it is not used for the Debezium connector to save data. The Debezium connector saves data in the following 4 types of topics:
+ The Debezium connector saves data in the following 4 types of topics:
- One topic named with the database server name ( `database.server.name`) for storing the database metadata messages, such as `public/default/database.server.name`.
- One topic (`database.history.pulsar.topic`) for storing the database history information. The connector writes and recovers DDL statements on this topic.