【问题标题】:Is kafka jdbc sink can create indexed table?kafka jdbc sink可以创建索引表吗?
【发布时间】:2020-11-11 21:23:26
【问题描述】:

我的 JDBC 接收器存在延迟问题。当我使用insert.mode=upsert 运行我的 JDBC 接收器时,每条消息进入 SQL Server 大约需要 10 秒。我的主管建议使用可以减少更新时间消耗的索引表。我还是 JDBC Sink 的新手,我想问一下如果 JDBC Sink 不存在并且 auto.create 选项为 true 时是否有能力创建索引表?

【问题讨论】:

    标签: sql-server apache-kafka apache-kafka-connect


    【解决方案1】:

    根据来源 JDBC Sink Connector creates 表只有主键(没有其他索引)。

    您可以从单元测试中看到 SQL Server 的 examplesCREATE 语句。

    【讨论】:

    • 这对我来说是一个缺点,因为如果没有创建索引,如果行数增加,性能会减少
    • 您可以手动添加索引或创建带有索引的整个表
    • 我已经读到 jdbc sink 中 upsert 模式的 sql server 语法是合并的,就像我现在使用的那样。我想知道合并语法的条件是基于表 PK 还是其他?
    猜你喜欢
    • 1970-01-01
    • 1970-01-01
    • 2021-01-22
    • 2020-05-28
    • 1970-01-01
    • 2019-10-20
    • 2020-09-25
    • 2021-12-21
    • 1970-01-01
    相关资源
    最近更新 更多