kafka-connect JDBC PostgreSQL Sink 连接器显式定义 PostgrSQL 模式（命名空间）

Question

我正在使用 JDBC 接收器连接器将数据写入 postgresql。

连接器工作正常，但连接器似乎只能将数据写入名为 public

的默认 postgresql 模式

这是 postgresql 的通用 JDBC URL 格式。

jdbc:postgresql://<host>:<port5432>/<database>

是否可以显式定义我需要 postgresql 接收器连接器写入的架构名称？

更新:

谢谢@Laurenz Albe 的提示。我可以在 jdbc 连接 URL 中定义 search_path，如以下任一：

jdbc:postgresql://<host>:<port>/<database>?options=-c%20search_path=myschema,public

jdbc:postgresql://<host>:<port>/<database>?currentSchema=myschema

Answer 1

使用options连接参数设置search_path:

jdbc:postgresql://<host>:<port5432>/<database>?options=-c%20search_path=myschema,public

kafka-connect JDBC PostgreSQL Sink Connector explicitly define the PostgrSQL schema (namespace)