pulsar-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From GitBox <...@apache.org>
Subject [GitHub] [pulsar] Anonymitaet commented on a change in pull request #4376: [issue #4074][pulsar-io]Update document of PostgreSQL for debezium
Date Mon, 27 May 2019 12:36:41 GMT
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_r287757089
 
 

 ##########
 File path: site2/docs/io-cdc-debezium.md
 ##########
 @@ -135,4 +129,106 @@ mysql> UPDATE products SET name='1111111111' WHERE id=101;
 mysql> UPDATE products SET name='1111111111' WHERE id=107;
 ```
 
-- In above subscribe topic terminal tab, we could find that 2 changes has been kept into
products topic.
\ No newline at end of file
+- In above subscribe topic terminal tab, we could find that 2 changes has been kept into
products topic.
+
+### Configuration Example from PostgreSQL
+
+
+Here is a configuration Json example:
+
+```json
+{
+    "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"
+}
+```
+
+
+You could also find the yaml example in this [file](https://github.com/apache/pulsar/blob/master/pulsar-io/debezium/postgres/src/main/resources/debezium-postgres-source-config.yaml),
which has similar content below:
+
+```yaml
+tenant: "public"
+namespace: "default"
+name: "debezium-postgres-source"
+topicName: "debezium-postgres-topic"
+archive: "connectors/pulsar-io-debezium-postgres-{{pulsar:version}}.nar"
+
+parallelism: 1
+
+configs:
+  ## config for pg, docker image: debezium/example-postgress:0.8
+  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_CONFIG
+  pulsar.service.url: "pulsar://127.0.0.1:6650"
+```
+
+### Usage example from PostgreSQL
+
+Here is a simple example to store PostgreSQL change data using above example config.
+
+- Start a PostgreSQL server with an example database, from which Debezium can capture changes.
 
 Review comment:
   ```suggestion
   1. Start a PostgreSQL server with an example database, from which Debezium can capture
changes.
   ```
   
   
   

----------------------------------------------------------------
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

Mime
View raw message