valitydev/clickhouse-sink-connector
14
0
Fork 0
mirror of https://github.com/valitydev/clickhouse-sink-connector.git synced 2024-11-06 02:25:18 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

Set JDBC url to include database name

Browse Source
This commit is contained in:
Kanthi Subramanian 2023-06-30 10:50:38 -04:00
parent 288359aab6
commit f2f32277a0
3 changed files with 9 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
sink-connector-lightweight/docker/config.yml
View File

@ -17,7 +17,7 @@ offset.flush.interval.ms: 5000
connector.class: "io.debezium.connector.mysql.MySqlConnector" connector.class: "io.debezium.connector.mysql.MySqlConnector"
offset.storage: "io.debezium.storage.jdbc.offset.JdbcOffsetBackingStore" offset.storage: "io.debezium.storage.jdbc.offset.JdbcOffsetBackingStore"
offset.storage.offset.storage.jdbc.offset.table.name: "altinity_sink_connector.replica_source_info" offset.storage.offset.storage.jdbc.offset.table.name: "altinity_sink_connector.replica_source_info"
offset.storage.jdbc.url: "jdbc:clickhouse://clickhouse:8123" offset.storage.jdbc.url: "jdbc:clickhouse://clickhouse:8123/altinity_sink_connector"
offset.storage.jdbc.user: "root" offset.storage.jdbc.user: "root"
offset.storage.jdbc.password: "root" offset.storage.jdbc.password: "root"
offset.storage.offset.storage.jdbc.offset.table.ddl: "CREATE TABLE if not exists %s offset.storage.offset.storage.jdbc.offset.table.ddl: "CREATE TABLE if not exists %s
@ -34,7 +34,7 @@ ORDER BY id
SETTINGS index_granularity = 8198" SETTINGS index_granularity = 8198"
offset.storage.offset.storage.jdbc.offset.table.delete: "delete from %s where 1=1" offset.storage.offset.storage.jdbc.offset.table.delete: "delete from %s where 1=1"
schema.history.internal: "io.debezium.storage.jdbc.history.JdbcSchemaHistory" schema.history.internal: "io.debezium.storage.jdbc.history.JdbcSchemaHistory"
schema.history.internal.jdbc.url: "jdbc:clickhouse://clickhouse:8123" schema.history.internal.jdbc.url: "jdbc:clickhouse://clickhouse:8123/altinity_sink_connector"
schema.history.internal.jdbc.user: "root" schema.history.internal.jdbc.user: "root"
schema.history.internal.jdbc.password: "root" schema.history.internal.jdbc.password: "root"
schema.history.internal.jdbc.schema.history.table.ddl: "CREATE TABLE if not exists %s schema.history.internal.jdbc.schema.history.table.ddl: "CREATE TABLE if not exists %s

2
sink-connector-lightweight/src/test/java/com/altinity/clickhouse/debezium/embedded/cdc/DebeziumChangeEventCaptureTest.java Normal file
View File

@ -0,0 +1,2 @@
package com.altinity.clickhouse.debezium.embedded.cdc;public class DebeziumChangeEventCaptureTest {
}

5
sink-connector-tools/loader.go Normal file
View File

@ -0,0 +1,5 @@
package main
func main() {
}