在 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 在邮件列表中回答了这个问题;我转述了他的回答。)