gearpump {

  streaming {
    ## We will timeout the task if it cannot register itself to AppMaster in time.
    register-task-timeout-ms = 60000

    ## ack once after sending ack-once-every-message-count messages.
    ack-once-every-message-count = 100

    ## max pending message per task to task connection. If pending message size is
    ## over this, then the flow control will not allow further sending.
    ## This value should be bigger than ack-once-every-message-count
    max-pending-message-count-per-connection = 1000

  }

  ### Flag to enable metrics
  metrics {
    akka {

      ### Whitelist for Metrics Aggregator class.
      ### See class [[MetricsAggregator]] for more information.
      metrics-aggregator-class {
        "org.apache.gearpump.streaming.metrics.TaskFilterAggregator" = ""
        "org.apache.gearpump.streaming.metrics.ProcessorAggregator" = ""
      }
    }
  }

  transport.serializer = "org.apache.gearpump.streaming.task.StreamingTransportSerializer"
}