根据合流文献中的例子(https://docs.confluent.io/3.1.1/connect/connect-jdbc/docs/sink_connector.html)我正试图找到一个可行的解决方案，在那里我可以重用以前遗留系统中已经存在的表，并且来自某个特定主题的所有消息都将通过“打乱”写入其中。
因此，一般来说，基于confluent的示例，如何将主题顺序中的所有消息写入名为“myorders”的表（该表已经存在），而不是在数据库中自动创建一个与主题名称同名的新表？
根据合流文献中的例子(https://docs.confluent.io/3.1.1/connect/connect-jdbc/docs/sink_connector.html)我正试图找到一个可行的解决方案，在那里我可以重用以前遗留系统中已经存在的表，并且来自某个特定主题的所有消息都将通过“打乱”写入其中。
因此，一般来说，基于confluent的示例，如何将主题顺序中的所有消息写入名为“myorders”的表（该表已经存在），而不是在数据库中自动创建一个与主题名称同名的新表？
1条答案
按热度按时间guykilcj1#
通过在配置中将auto.create设置为true，可以自动创建不存在的表。
但是，现成的jdbc接收器连接器可以重用“myorders”表。
请看https://docs.confluent.io/current/connect/kafka-connect-jdbc/sink-connector/index.html#auto-创建和自动演化
这适用于当前文档和链接的confluent platform 3.1.1版本。