KAFKA JDBC Source 连接器添加了默认模式

Question

我使用 KAFKA JDBC 源连接器从数据库 ClickHouse（驱动程序 - clickhouse-jdbc-0.2.4.jar）中读取并增加 mod。 设置：

    batch.max.rows = 100
    catalog.pattern = null
    connection.attempts = 3
    connection.backoff.ms = 10000
    connection.password = [hidden]
    connection.url = jdbc:clickhouse://<ip>:8123/<schema>
    connection.user = user
    db.timezone = 
    dialect.name = 
    incrementing.column.name = id
    mode = incrementing
    numeric.mapping = null
    numeric.precision.mapping = false
    poll.interval.ms = 5000
    query = 
    query.suffix = 
    quote.sql.identifiers = never
    schema.pattern = null
    table.blacklist = []
    table.poll.interval.ms = 60000
    table.types = [TABLE]
    table.whitelist = [<table_name>]
    tables = [default.<schema>.<table_name>]
    timestamp.column.name = []
    timestamp.delay.interval.ms = 0
    timestamp.initial = null
    topic.prefix = staging-
    validate.non.null = false

为什么连接器还要替代默认方案？以及如何避免？

而不是请求

SELECT * FROM <schema>.<table_name> WHERE <schema>.<table_name>.id > ? ORDER BY <schema>.<table_name>.id ASC

我收到一个错误

SELECT * FROM default.<schema>.<table_name> WHERE default.<schema>.<table_name>.id > ? ORDER BY default.<schema>.<table_name>.id ASC

Answer 1

您可以像下面这样创建 CH 数据源对象（其中不传递架构名称）。

final ClickHouseDataSource dataSource = new ClickHouseDataSource(
        "jdbc:clickhouse://"+host+"/"+user+"?option1=one%20two&option2=y"); 

然后在 SQL 查询中，你可以指定一个模式名称（schema.table）。因此它不会在您的查询中添加默认架构。