我的要求是每天流式传输数百万条记录，并且它在外部配置参数上有很大的依赖关系。例如，用户可以随时更改Web应用程序中所需的设置，并且在进行更改后，必须使用新的应用程序配置参数来进行流式传输。这些是应用程序级别的配置，我们还有一些需要通过每个数据传递并进行过滤的动态排除参数。 我发现Flink没...

首先，我阅读了此帖子，关于同样的问题（链接），并尝试按照相同的解决方案进行操作（使用mvn创建一个新的快速入门项目并将代码迁移到其中），但是即使在IntelliJ的开箱即用情况下也无法正常工作。 这是我的pom.xml与另一个pom.xml中的依赖项混合在一起。我做错了什么？ <!-...

我们正在构建一个物联网云平台项目的开端。要实现完整的物联网平台解决方案，有一些已知的部分需要完成。其中之一是实时规则处理/引擎系统，该系统需要理解流事件与由最终用户以可读格式定义的任何规则（如SQL或Drools if/when/then等）动态匹配。 我很困惑，因为互联网上有很多产品、项目...