在 Apache Flink/Ververica CE 中添加自定义连接器
Adding a custom connector in Apache Flink/Ververica CE
Apache Flink/Ververica 社区版 - 问题
我正在尝试向 Ververica 社区版添加自定义连接器,但一直出现以下错误:
“罐子包含多个连接器。请选择一个。”,它不允许我选择更多的罐子。我正在使用以下 repo 生成的自定义连接器进行测试:https://github.com/deadwind4/slink/tree/master/connector-es6
我的具体问题是这个回购中有什么具体缺失我们应该添加到 signal ververica 关于自定义记录。
错误消息具有误导性,问题在于未找到连接器。
这是因为Ververica Platform 只支持new connector interfaces。
工厂发现还需要 META-INF/services
中的一个条目,该条目似乎丢失了。
有关实现这些接口的连接器示例,请参阅 https://github.com/Airblader/flink-connector-imap and https://github.com/knaufk/flink-faker。
(Ingo Bürk 在邮件列表中回答了这个问题;我转述了他的回答。)
Apache Flink/Ververica 社区版 - 问题
我正在尝试向 Ververica 社区版添加自定义连接器,但一直出现以下错误: “罐子包含多个连接器。请选择一个。”,它不允许我选择更多的罐子。我正在使用以下 repo 生成的自定义连接器进行测试:https://github.com/deadwind4/slink/tree/master/connector-es6
我的具体问题是这个回购中有什么具体缺失我们应该添加到 signal ververica 关于自定义记录。
错误消息具有误导性,问题在于未找到连接器。
这是因为Ververica Platform 只支持new connector interfaces。
工厂发现还需要 META-INF/services
中的一个条目,该条目似乎丢失了。
有关实现这些接口的连接器示例,请参阅 https://github.com/Airblader/flink-connector-imap and https://github.com/knaufk/flink-faker。
(Ingo Bürk 在邮件列表中回答了这个问题;我转述了他的回答。)