将现有的表用于 Confluent JDBC 接收器连接器



根据 confluent 文档 (https://docs.confluent.io/3.1.1/connect/connect-jdbc/docs/sink_connector.html( 中的示例,我正在尝试让解决方案正常工作,我可以重用以前遗留系统中已经存在的表,并且来自某个主题的所有消息都应通过"不安"写入其中。

因此,通常基于 confluent 中的示例,如何将来自主题订单的所有消息写入名为"myOrders"的表(已经存在(,而不是在我的数据库中自动创建一个与主题名称同名的新表?

如果表不存在,可以通过在配置中将 auto.create 设置为 true 来自动创建该表。

但是,开箱即用的 JDBC 接收器连接器可以重用您的"myOrders"表。

请参阅 https://docs.confluent.io/current/connect/kafka-connect-jdbc/sink-connector/index.html#auto-creation-and-auto-evoluton

这适用于当前文档和您链接的 Confluent Platform 3.1.1 版本。

最新更新