仓库指标
- Star
- (13,697 star)
- PR 合并指标
- (平均合并 3天 10小时) (30 天内合并 146 个 PR)
描述
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 !!!
