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



Apache Flink/Ververica社区版-问题

我正在尝试将自定义连接器添加到ververica社区版,但一直出现以下错误:"jar包含多个连接器。请选择一个&";,它不允许我选择更多的罐子。我正在使用以下回购生成的自定义连接器进行测试:https://github.com/deadwind4/slink/tree/master/connector-es6

我的具体问题是,这个回购中缺少任何我们应该添加的特定内容,以向ververica发出关于自定义记录的信号。

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

这是因为Ververica平台只支持新的连接器接口。工厂发现还需要META-INF/services中的一个条目,该条目似乎已丢失。

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

(这是Ingo Bürk在邮件列表上回复的;我转述了他的回复。(

最新更新