在 Apache Flink/Ververica CE 中添加自定义连接器答案

【问题标题】：Adding a custom connector in Apache Flink/Ververica CE在 Apache Flink/Ververica CE 中添加自定义连接器
【发布时间】：2021-08-12 15:40:00
【问题描述】：

Apache Flink/Ververica 社区版 - 问题

我正在尝试将自定义连接器添加到 ververica 社区版并不断给我以下错误： “jar 包含多个连接器。请选择一个。”，它不允许我选择更多的 jar。我正在使用以下 repo 生成的自定义连接器进行测试：https://github.com/deadwind4/slink/tree/master/connector-es6

我的具体问题是，此存储库中是否缺少任何具体内容，我们应该添加以向 ververica 发出关于自定义记录的信号。

【问题讨论】：

标签： apache-flink flink-streaming flink-sql

【解决方案1】：

错误消息具有误导性，问题是未找到连接器。

这是因为 Ververica 平台仅支持 new connector interfaces。工厂发现还需要META-INF/services 中的条目，这似乎是缺失的。

有关实现这些接口的连接器示例，请参阅https://github.com/Airblader/flink-connector-imap 和https://github.com/knaufk/flink-faker。

（Ingo Bürk 在邮件列表中回答了这个问题；我已经转述了他的回答。）

【讨论】：

谢谢，起初我没有看到 SO 问题。 :-)