我想使用File节拍从服务器读取日志并在Apache上进行流。现在,我们正在使用Filebeat -> Kafka ->Flink。
我想移除卡夫卡,让它成为Filebeat -> Flink
感谢你的回应/建议。
发布于 2022-08-31 08:30:23
您将需要创建一个自定义源连接器。对于Table,这在https://nightlies.apache.org/flink/flink-docs-master/docs/dev/table/sourcessinks/中有详细说明。您也可以阅读翻转-27,它描述了源接口。https://cwiki.apache.org/confluence/display/FLINK/FLIP-27%3A+Refactor+Source+Interface
https://stackoverflow.com/questions/73489708
复制相似问题