[GitHub] [pulsar] Anonymitaet commented on a change in pull request #4376: [issue #4074][pulsar-io]Update document of PostgreSQL for debezium

[GitBox <gi...@apache.org>]

Anonymitaet commented on a change in pull request #4376: [issue #4074][pulsar-io]Update document of PostgreSQL for debezium
URL: https://github.com/apache/pulsar/pull/4376#discussion_r287726983
 
 

 ##########
 File path: site2/docs/io-cdc-debezium.md
 ##########
 @@ -26,56 +26,44 @@ The Configuration is mostly related to Debezium task config, besides this we sho
 | `pulsar.service.url` | `true` | `null` | Pulsar cluster service url. |
 | `offset.storage.topic` | `true` | `null` | Record the last committed offsets that the connector successfully completed. |
 
-### Configuration Example
+### Configuration Example from MySql
 
 Here is a configuration Json example:
 
-```$json
+```json
 {
-    "tenant": "public",
-    "namespace": "default",
-    "name": "debezium-kafka-source",
-    "className": "org.apache.pulsar.io.kafka.connect.KafkaConnectSource" ,
-    "topicName": "kafka-connect-topic",
-    "configs":
-    {
-        "task.class": "io.debezium.connector.mysql.MySqlConnectorTask",
-        "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",
-        "value.converter": "org.apache.kafka.connect.json.JsonConverter",
-        "pulsar.service.url": "pulsar://127.0.0.1:6650",
-        "offset.storage.topic": "offset-topic"
-    },
-    "archive": "connectors/pulsar-io-debezium-mysql-{{pulsar:version}}.nar"
+    "task.class": "io.debezium.connector.mysql.MySqlConnectorTask",
+    "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",
+    "value.converter": "org.apache.kafka.connect.json.JsonConverter",
+    "pulsar.service.url": "pulsar://127.0.0.1:6650",
+    "offset.storage.topic": "offset-topic"
 }
 ```
 
-You could also find the yaml example in this [file](https://github.com/apache/pulsar/blob/master/pulsar-io/kafka-connect-adaptor/src/main/resources/debezium-mysql-source-config.yaml), which has similar content below:
+You could also find the yaml example in this [file](https://github.com/apache/pulsar/blob/master/pulsar-io/debezium/mysql/src/main/resources/debezium-mysql-source-config.yaml), which has similar content below:
 
 Review comment:
   ```suggestion
   Optionally, you can create a `debezium-mysql-source-config.yaml` file, and copy the [contents] (https://github.com/apache/pulsar/blob/master/pulsar-io/debezium/mysql/src/main/resources/debezium-mysql-source-config.yaml) below to the `debezium-mysql-source-config.yaml` file.
   ```

----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
users@infra.apache.org


With regards,
Apache Git Services