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

siddhi-io / distribution

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