Repository metrics
- Stars
- (13,697 stars)
- PR merge metrics
- (Avg merge 3d 10h) (146 merged PRs in 30d)
Description
Hi , I created a JDBC sink connector to persist the messages from pulsar topic to postgresql database . I am running latest version of pulsar through docker .
Followed this document : https://pulsar.apache.org/docs/en/io-quickstart/#create-a-jdbc-sink
This command is to create a sink :
$ bin/pulsar-admin sinks create
--archive ./connectors/pulsar-io-jdbc-postgres-2.8.1.nar
--inputs my-topic
--name jdbc-postgres-sink
--sink-config-file ./connectors/pulsar-postgres-jdbc-sink.yaml
--parallelism 1
This is my yaml (pulsar-postgres-jdbc-sink.yaml) file content :
tenant: "public" namespace: "default" name: "jdbc-postgres-sink" topicName: "persistent://public/default/my-topic" sinkType: "jdbc-postgres" configs: userName: "postgres" password: "password" jdbcUrl: "jdbc:postgresql://localhost:5432/pulsar_postgres_jdbc_sink" tableName: "pulsar_postgres
After creation of sink , i didn't see any data inside postgre database and the sink running status is "false" . Please help on the same . Thanks !!!
