Kafka + Transit = Niceness

test.clj

(ns project.core
    (:require [cognitect.transit :as transit])
    (:use kafka-clj.client :reload)
    (:import [java.io ByteArrayInputStream ByteArrayOutputStream]))
  
;; Set up connector here

(let [data (ByteArrayOutputStream. 4096)
                   writer (transit/writer data :json)]
               (transit/write writer link-difference)
               (send-msg connector channel (.toByteArray data)))