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