apache-flink - 我应该选择哪种开源CEP来进行分布式和流水线处理;悉地、弗林克、埃斯珀?

标签 apache-flink complex-event-processing esper siddhi

我不太喜欢 siddhi cep,因为它有 siddhi 查询语言,但它使用 Storm 进行分布式处理,并且 WSO2 提供了一个 Web 界面/仪表板来创建和部署应用程序。我认为这会减少我增强/使用某些功能的独立性。

另一方面,Flink 似乎是不错的选择,但它需要大量代码来实现即使是简单的逻辑。

还有比这些更好的选择吗? 困惑

最佳答案

独立性较低是什么意思?您可以使用 Siddhi 4.x [1],而不依赖于 Storm,通过使用其源和接收器功能,使用 tcp、Kafka、http 等从一个实例接收消息并将消息发送到另一个实例。 WSO2 流处理器还使用新版本的 Siddhi 及其编辑器,您可以模拟事件并进行调试。

更新:从 4.1 开始,[WSO2 流处理器][2] 可以以完全分布式模式运行在 Kafka 之上。请参阅https://docs.wso2.com/display/SP4xx/Fully+Distributed+Deployment

[1] https://wso2.github.io/siddhi/

[2] https://wso2.com/analytics

关于apache-flink - 我应该选择哪种开源CEP来进行分布式和流水线处理;悉地、弗林克、埃斯珀?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/45870179/

相关文章:

apache-flink - 窗口操作符行为澄清后的 Apache Flink KeyedStream

visual-studio - 适用于 Visual Studio 的 Azure 流分析工具 : Error when executing aggregated queries - "Object reference not set to an instance of an object"

java - Apache Flink + CEP - 检测相同事件

java - Esper:注意,当事件数量(具有特定参数)超过阈值时

concurrency - esper和update listener并发

docker - 由于正在进行的领导人选举,该服务暂时不可用。请刷新

amazon-s3 - 无法执行HTTP请求: Timeout waiting for connection from pool in Flink

java - Apache Flink 与 Elasticsearch 集成

java - 埃斯珀何时知道时间窗口已经结束

java - 连接 Esper 和 PostgreSQL