Question: Pulsar IO JDBC Java class example (Clickhouse)

[Redirts]

From what I understand it is possible to create a custom Java class that reads from pulsar and writes via JDBC to a database (in my I would like it to be clickhouse).

https://github.com/apache/pulsar/blob/master/pulsar-io/jdbc/clickhouse/src/main/java/org/apache/pulsar/io/jdbc/ClickHouseJdbcAutoSchemaSink.java

Can anyone provide a complete code example to make this JDBC Sink work?

Thanks

[jiazhai]

@Redirts is this link help? https://pulsar.apache.org/docs/en/io-quickstart/#connect-pulsar-to-postgresql

[jiazhai]

would also like to have @vzhikserg in the thread, who is the author for clickhouse connector.

[Redirts]

Hi, The link you provide describes setting up the jdbc sink without writing any line of code. I would like to be able to manipulate the data before it is sent to clickhouse via java code. Thanks

…

On Wed, 21 Oct 2020, 03:02 Jia Zhai, ***@***.***> wrote: would also like to have @vzhikserg <https://github.com/vzhikserg> in the thread, who is the author for clickhouse connector. — You are receiving this because you were mentioned. Reply to this email directly, view it on GitHub <#8279 (comment)>, or unsubscribe <https://github.com/notifications/unsubscribe-auth/AFTD2N7EYXUZV6KE3GZ2PH3SLY6JVANCNFSM4STRLKHA> .

[tisonkun]

@Redirts you can fork and patch the upstream ClickHouse connector for your use case in this situation.