Deploying WSO2 Streaming Integrator on AWS ECS in Minimum HA Mode

Creating a VPC

Setting up the Cluster

Creating a Task for Streaming Integrator’s First Node

Create a new Task Definition

Creating a Task for Streaming Integrator’s Second Node

Create a service using the Task (ha-node1-task) for the First Node

Create a service using the Task (ha-node2-task) for the Second Node

  • Task definition: ha-node2-task
  • Service name: ha-node2-service

Viewing the Status of the servers

Checking on Streaming Integrator Cluster via the CloudWatch Logs

Active Node Logs

[2020–03–20 20:18:48,283] INFO {org.wso2.carbon.streaming.integrator.core.ha.HAManager} — HA Deployment: Starting up as Active Node[2020–03–20 20:18:52,261] INFO {org.wso2.carbon.kernel.internal.CarbonStartupHandler} — WSO2 Streaming Integrator started in 44.893 sec[2020–03–20 20:19:46,595] INFO {org.wso2.carbon.streaming.integrator.core.persistence.PersistenceManager} — Siddhi apps persisted successfully

Passive Node Logs

[2020–03–20 20:38:14,390] INFO {org.wso2.carbon.streaming.integrator.core.ha.HAManager} — HA Deployment: Starting up as Passive Node[2020–03–20 20:38:18,287] INFO {org.wso2.carbon.kernel.internal.CarbonStartupHandler} — WSO2 Streaming Integrator started in 46.604 sec

Confirming HA functionality

[2020–03–20 20:38:15,409] INFO {org.wso2.carbon.streaming.integrator.core.ha.HAEventListener} — memberAdded event received for node id : wso2-si-2[2020–03–20 20:38:15,455] INFO {org.wso2.carbon.streaming.integrator.core.ha.HAEventListener} — Active node retrieved node details of passive node
[2020–03–20 20:38:46,587] INFO {org.wso2.carbon.streaming.integrator.core.persistence.PersistenceManager} — Siddhi apps persisted successfully

--

--

Get the Medium app

A button that says 'Download on the App Store', and if clicked it will lead you to the iOS App store
A button that says 'Get it on, Google Play', and if clicked it will lead you to the Google Play store