Kafka JDBC Sink 连接器与 PostgreSQL 12 兼容吗?

Posted

技术标签:

【中文标题】Kafka JDBC Sink 连接器与 PostgreSQL 12 兼容吗?【英文标题】:Kafka JDBC Sink Connector compatibly works with PostgreSQL 12? 【发布时间】:2021-01-22 12:06:27 【问题描述】:

我正在寻找提到 Kafka JDBC Sink Connector(由 Confluent 开发)可以很好地使用的兼容数据库的文档。但是,我看不到任何文件提到那个。

在将我们的数据库从 Postgres 9.5 升级到 Postgres 12 后,我发现插入性能问题。想知道这是否是由我们正在使用的当前 JDBC 连接器版本或任何其他原因引起的。

请给我你的建议。

【问题讨论】:

你使用的是什么版本的 Kafka JDBC Sink Connector? 我们使用的是 Confluent 5.0.0 【参考方案1】:

您应该能够从指定使用哪些驱动程序版本的源代码中推断出支持哪些数据库

https://github.com/confluentinc/kafka-connect-jdbc/blob/master/pom.xml#L59

您还可以查看可用的方言

https://github.com/confluentinc/kafka-connect-jdbc/tree/master/src/main/java/io/confluent/connect/jdbc/dialect

【讨论】:

以上是关于Kafka JDBC Sink 连接器与 PostgreSQL 12 兼容吗?的主要内容,如果未能解决你的问题,请参考以下文章

如何解决配置中设置的 Kafka JDBC Sink 连接器中与 TopicRecordName 与 TopicNameStrategy 的冲突

kafka 连接器 jdbc-sink 最后出现语法错误

提取和转换 jdbc sink 连接器的 kafka 消息特定字段

为jdbc sink连接器提取和转换kafka消息的特定字段。

如何使用 kafka 连接 JDBC sink 和 source 使用 python

如何使用 FME 处理 Kafka JDBC Sink 连接器