Tranquility Server

Tranquility helps you send real-time event streams to Druid and handles partitioning, replication, service discovery, and schema rollover, seamlessly and without downtime. You only have to define your Druid schema.

If you have a program that generates a stream, then you can push that stream directly into Druid in real-time. With this approach, Tranquility is embedded in your data-producing application. Tranquility comes with bindings for the Storm and Samza stream processors. It also has a direct API that can be used from any JVM-based program, such as Spark Streaming or a Kafka consumer.

For examples and more information, please see the Tranquility README.

The documentation suggest to colocate the Transquility servers with the Druid middleManagers and historical processes.

module.exports =
  deps:
    krb5_client: module: 'masson/core/krb5_client', local: true
    java: module: 'masson/commons/java', local: true, recommanded: true
    iptables: module: 'masson/core/iptables', local: true
    druid: module: 'ryba/druid/base', local: true, auto: true, implicit: true
    druid_tranquility: module: 'ryba/druid/tranquility'
  configure:
    'ryba/druid/tranquility/configure'
  commands:
    'prepare':
      'ryba/druid/tranquility/prepare'
    'install': [
      'ryba/druid/tranquility/install'
      'ryba/druid/tranquility/start'
    ]
    # 'start':
    #   'ryba/druid/tranquility/start'
    # 'status':
    #   'ryba/druid/tranquility/status'
    # 'stop':
    #   'ryba/druid/tranquility/stop'