 (defn my-inc [{:keys [n] :as segment}]
   (assoc segment :n (inc n)))
 
-(def logging-config 
-  {:appenders {:standard-out {:enabled? false}
-               :spit {:enabled? false}
-               :rotor {:min-level :trace
-                       :enabled? true
-                       :async? false
-                       :max-message-per-msecs nil
-                       :fn rotor/appender-fn}}
-   :shared-appender-config {:rotor {:path "onyx-benchmark.log"
-                                    :max-size (* 512 102400) :backlog 5}}})
-
 (defn -main [zk-addr riemann-addr id n-peers messaging & args]
   (let [peer-config {:zookeeper/address zk-addr
                      :onyx/id id

                     ;:onyx.messaging.aeron/embedded-driver? false
                     :onyx.peer/join-failure-back-off 500
                     :onyx.peer/job-scheduler :onyx.job-scheduler/greedy
                     :onyx.messaging/impl (keyword messaging)
                     :onyx.log/config logging-config}
        n-peers-parsed (Integer/parseInt n-peers)
        peer-group (onyx.api/start-peer-group peer-config)
        peers (onyx.api/start-peers n-peers-parsed peer-group)]

  (:require [clojure.core.async :refer [chan dropping-buffer <!!]]
            [riemann.client :as r]
            [onyx.peer.pipeline-extensions :as p-ext]
            [taoensso.timbre :refer  [info warn trace fatal error] :as timbre]
            [interval-metrics.core :as im]
            [onyx.plugin.bench-plugin]
