我想使用Filebeat从服务器读取日志，并在Apache Flink上进行流式传输。现在我们正在使用Filebeat->卡夫卡->Flink。
我想删除Kafka并使其成为Filebeat->闪烁
感谢您的回复/建议。
您将需要创建一个自定义源连接器。对于API表，这在https://nightlies.apache.org/flink/flink-docs-master/docs/dev/table/sourcessinks/.您还可以阅读FLIP-27，其中描述了Source接口。https://cwiki.apache.org/confluence/display/FLINK/FLIP-27%3A+重构器+源+接口
javascript python java c# php android html jquery c++ css ios sql mysql arrays asp.net json python-3.x ruby-on-rails .net sql-server django objective-c excel regex ruby linux ajax iphone xml vba spring asp.net-mvc database wordpress string postgresql wpf windows xcode bash git oracle list vb.net multithreading eclipse algorithm macos powershell visual-studio image forms numpy scala function api selenium