WSO2 SP 中的 Siddhi 应用程序如何在重新部署期间处理传入的数据流?
How Siddhi application in WSO2 SP handles an incoming data stream during redeployment?
这个话题对我来说太大了,我正在努力寻找一个明确的问题。我在 WSO2 流处理器文档中找不到任何东西。
我在一台机器上部署了 WSO2 SP。没有 Kafka 集成,只启用了数据库持久性。 Siddhi 应用程序中的源是 HTTP 类型,因此有另一个服务将事件发送到它的端点。在重新部署 Siddhi 应用程序期间,很明显,它变得不可用,但外部服务仍在发送事件。 WSO2SP/Siddhi 应用程序如何避免丢失与其状态无关的事件?
经过进一步调查和捕获指标,似乎在部署期间 Siddhi 应用程序确实变得不可用。测试是在单节点部署上完成的,而不是 Minimum HA。因此,馈送服务假设在发送事件时具有重试逻辑。
这个话题对我来说太大了,我正在努力寻找一个明确的问题。我在 WSO2 流处理器文档中找不到任何东西。
我在一台机器上部署了 WSO2 SP。没有 Kafka 集成,只启用了数据库持久性。 Siddhi 应用程序中的源是 HTTP 类型,因此有另一个服务将事件发送到它的端点。在重新部署 Siddhi 应用程序期间,很明显,它变得不可用,但外部服务仍在发送事件。 WSO2SP/Siddhi 应用程序如何避免丢失与其状态无关的事件?
经过进一步调查和捕获指标,似乎在部署期间 Siddhi 应用程序确实变得不可用。测试是在单节点部署上完成的,而不是 Minimum HA。因此,馈送服务假设在发送事件时具有重试逻辑。