add message piping back; to-clojure conversion to KafkaMessage added by default
add queue-capacity option for zookeeper messages: can be used to limit LinkedBlockingQueue queue size with large messages