为 Confluent JDBC Sink Connector 使用现有的表

Question

根据 confluent docs (https://docs.confluent.io/3.1.1/connect/connect-jdbc/docs/sink_connector.html) 中的示例，我正在尝试找到一个可行的解决方案，在该解决方案中，我可以从以前的遗留系统中重用我已经存在的表，并且来自某个主题的所有消息都应通过“心烦意乱”来编写"进去。

因此，一般而言，基于 confluent 的示例，我如何将主题订单中的所有消息写入名为“myOrders”（已经存在）的表中，而不是在我的数据库中自动创建一个同名的新表主题名称？

Answer 1

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

但是，开箱即用的 JDBC Sink 连接器可以重用您的“myOrders”表。

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

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