DataBridge (Thrift or Binary) not working with Siddhi-Runner 5.1.2

[lokkeshjaya]

Description: Databridge configurations not working with siddhi-runner 5.1.2

Affected Product Version: siddhi-runner 5.1.2

Suggested Assignees: @BuddhiWathsala @mohanvive @niveathika

Steps to reproduce:

• Enable the data bridge configurations as suggested in the siddhi 5.1.x documentation -https://siddhi.io/en/v5.1/docs/config-guide/#configuring-databridge-transport
• On running the siddhi-runner neither the thrift nor binary data bridge gets started.

Logs:

JAVA_HOME environment variable is set to C:\Program Files\Java\jdk1.8.0_144 CARBON_HOME environment variable is set to D:_Lokkesh\TML\SW\siddhi-runner-5.1.2\bin.. RUNTIME_HOME environment variable is set to D:_Lokkesh\TML\SW\siddhi-runner-5.1.2\wso2\runner\bin.. RUNTIME environment variable is set to runner osgi> [2020-07-06 12:59:21,489] INFO {org.wso2.msf4j.internal.websocket.WebSocketServerSC} - All required capabilities are available of WebSocket service component is available. [2020-07-06 12:59:22,554] INFO {org.wso2.carbon.metrics.core.config.model.JmxReporterConfig} - Creating JMX reporter for Metrics with domain 'org.wso2.carbon.metrics' [2020-07-06 12:59:22,577] INFO {org.wso2.msf4j.analytics.metrics.MetricsComponent} - Metrics Component is activated [2020-07-06 12:59:22,581] INFO {org.wso2.carbon.databridge.agent.internal.DataAgentDS} - Successfully deployed Agent Server [2020-07-06 12:59:22,904] INFO {org.wso2.carbon.analytics.idp.client.core.utils.IdPServiceUtils} - Enabling default IdPClient Local User Store as configuration is not overridden. [2020-07-06 12:59:22,910] INFO {org.wso2.carbon.analytics.idp.client.core.utils.IdPServiceUtils} - IdP client of type 'local' is started. [2020-07-06 12:59:23,054] INFO {org.wso2.msf4j.internal.MicroservicesServerSC} - All microservices are available [2020-07-06 12:59:23,937] INFO {org.wso2.transport.http.netty.contractimpl.listener.ServerConnectorBootstrap$HttpServerConnector} - HTTP(S) Interface starting on host 0.0.0.0 and port 9090 [2020-07-06 12:59:23,937] INFO {org.wso2.transport.http.netty.contractimpl.listener.ServerConnectorBootstrap$HttpServerConnector} - HTTP(S) Interface starting on host 0.0.0.0 and port 9443

Used deployment.yaml configuration :

Carbon Configuration Parameters

wso2.carbon: # value to uniquely identify a server id: siddhi-runner # server name name: Siddhi Runner Distribution # ports used by this server ports: # port offset offset: 0

transports: http: listenerConfigurations: - id: "default" host: "0.0.0.0" port: 9090 - id: "msf4j-https" host: "0.0.0.0" port: 9443 scheme: https sslConfig: keyStore: "${carbon.home}/resources/security/wso2carbon.jks" keyStorePass: wso2carbon certPass: wso2carbon transportProperties: - name: "server.bootstrap.socket.timeout" value: 60 - name: "latency.metrics.enabled" value: false databridge: listenerConfigurations: workerThreads: 10 maxEventBufferCapacity: 10 eventBufferSize: 2000 keyStoreLocation: ${sys:carbon.home}/resources/security/wso2carbon.jks keyStorePassword: wso2carbon clientTimeoutMin: 30 # Data receiver configurations dataReceivers: - dataReceiver: type: Thrift properties: tcpPort: '7611' sslPort: '7711' - dataReceiver: type: Binary properties: tcpPort: '9611' sslPort: '9711' tcpReceiverThreadPoolSize: '100' sslReceiverThreadPoolSize: '100' hostName: 0.0.0.0 senderConfigurations: agents: - agentConfiguration: name: Thrift dataEndpointClass: org.wso2.carbon.databridge.agent.endpoint.thrift.ThriftDataEndpoint publishingStrategy: async trustStorePath: '${sys:carbon.home}/resources/security/client-truststore.jks' trustStorePassword: 'wso2carbon' queueSize: 32768 batchSize: 200 corePoolSize: 1 socketTimeoutMS: 30000 maxPoolSize: 1 keepAliveTimeInPool: 20 reconnectionInterval: 30 maxTransportPoolSize: 250 maxIdleConnections: 250 evictionTimePeriod: 5500 minIdleTimeInPool: 5000 secureMaxTransportPoolSize: 250 secureMaxIdleConnections: 250 secureEvictionTimePeriod: 5500 secureMinIdleTimeInPool: 5000 sslEnabledProtocols: TLSv1.1,TLSv1.2 ciphers: TLS_ECDHE_ECDSA_WITH_AES_128_CBC_SHA256,TLS_ECDHE_RSA_WITH_AES_128_CBC_SHA256,TLS_DHE_RSA_WITH_AES_128_CBC_SHA256,TLS_ECDHE_ECDSA_WITH_AES_128_CBC_SHA,TLS_ECDHE_RSA_WITH_AES_128_CBC_SHA,TLS_DHE_RSA_WITH_AES_128_CBC_SHA,TLS_ECDHE_ECDSA_WITH_AES_128_GCM_SHA256,TLS_ECDHE_RSA_WITH_AES_128_GCM_SHA256,TLS_DHE_RSA_WITH_AES_128_GCM_SHA256 - agentConfiguration: name: Binary dataEndpointClass: org.wso2.carbon.databridge.agent.endpoint.binary.BinaryDataEndpoint publishingStrategy: async trustStorePath: '${sys:carbon.home}/resources/security/client-truststore.jks' trustStorePassword: 'wso2carbon' queueSize: 32768 batchSize: 200 corePoolSize: 1 socketTimeoutMS: 30000 maxPoolSize: 1 keepAliveTimeInPool: 20 reconnectionInterval: 30 maxTransportPoolSize: 250 maxIdleConnections: 250 evictionTimePeriod: 5500 minIdleTimeInPool: 5000 secureMaxTransportPoolSize: 250 secureMaxIdleConnections: 250 secureEvictionTimePeriod: 5500 secureMinIdleTimeInPool: 5000 sslEnabledProtocols: TLSv1.1,TLSv1.2 ciphers: TLS_ECDHE_ECDSA_WITH_AES_128_CBC_SHA256,TLS_ECDHE_RSA_WITH_AES_128_CBC_SHA256,TLS_DHE_RSA_WITH_AES_128_CBC_SHA256,TLS_ECDHE_ECDSA_WITH_AES_128_CBC_SHA,TLS_ECDHE_RSA_WITH_AES_128_CBC_SHA,TLS_DHE_RSA_WITH_AES_128_CBC_SHA,TLS_ECDHE_ECDSA_WITH_AES_128_GCM_SHA256,TLS_ECDHE_RSA_WITH_AES_128_GCM_SHA256,TLS_DHE_RSA_WITH_AES_128_GCM_SHA256