Flink如何更改SQLServerCDC连接器工厂类的Identifier?
以下为热心网友提供的参考意见
在实时计算 Flink 中，更改 SQLServerCDC 连接器工厂类的 Identifier 需要进行以下操作：
克隆 GitHub 仓库，切换到指定版本的分支代码。
更改 SQLServerCDC 连接器工厂类的 Identifier。具体操作为：在 com.ververica.cdc.connectors.sqlserver.table.SqlServerTableFactory 类中，将 factoryIdentifier() 方法的返回值改为所需的连接器名字，例如 ‘sqlserver-cdc-test’。 ，此回答整理自钉群“实时计算Flink产品交流群”
以下为热心网友提供的参考意见
要更改Flink SQLServerCDC连接器工厂类的Identifier，需要修改SqlServerSourceOptions类中的identifier属性。
具体步骤如下：
-
找到
SqlServerSourceOptions类，该类位于org.apache.flink.connector.sqlservercdc.options包中。 -
打开该类，找到
identifier属性，将其修改为你想要的新值。例如，将identifier的值从”my-sqlserver-cdc-connector”改为”my-new-sqlserver-cdc-connector”。 -
保存修改后的代码。
-
重新编译并运行你的Flink应用程序，新的SQLServerCDC连接器工厂类的Identifier将会生效。
转转请注明出处：http://www.yunxiaoer.com/180438.html
