Skip to content

Instantly share code, notes, and snippets.

@shayanjm

shayanjm/test.clj

Created February 2, 2016 22:52
Show Gist options

  • Select an option

    Learn more about clone URLs
  • Save shayanjm/945dac3e419e58abfd12 to your computer and use it in GitHub Desktop.

Select an option

Learn more about clone URLs
Save shayanjm/945dac3e419e58abfd12 to your computer and use it in GitHub Desktop.
Download ZIP

Revisions

  1. shayanjm created this gist Feb 2, 2016.
    11 changes: 11 additions & 0 deletions test.clj
    View file
    Original file line number Diff line number Diff line change
    @@ -0,0 +1,11 @@
    (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)))