                      ;: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}
+                     :onyx.messaging/impl (keyword messaging)}
         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.appenders.rotor :as rotor]
            [taoensso.timbre :refer  [info warn trace fatal error] :as timbre]
            [interval-metrics.core :as im]
            [onyx.plugin.bench-plugin]

(defn my-inc [{:keys [n] :as segment}]
  (assoc segment :n (inc n)))

(defn -main [zk-addr riemann-addr id n-peers messaging & args]
  (let [peer-config {:zookeeper/address zk-addr
                     :onyx/id id
