 
 (defn init! [config]
   (init-log!      (:logging-options config))
-  ;; TODO: replace this with TRACKit
   (init-tracking! (:tracking config)))
 
 

;; and now that some of the not relevant stuff
;; have been moved out is a bit cleaner,
;; but still not clear enough...
;; NEED NORE clean loop
;;
(defn siphon [{:keys [kafka-source elasticsearch-target]}]
  (loop [consumer (connect-to-kafka kafka-source)

              updated-state (assoc state :consumer-offset next-consumer-offset)]
          ;; TODO: don't like this as it won't
          ;; consume more msgs until the check point is saved
          ;; this would be better off in a separate thread
          (set-consumer-offset updated-state)
          (recur consumer updated-state))))))

