kafka-clj.tcp-api — kafka-clj 4.0.3

remove secular dependancies from jaas to tcp

read-response clj

(read-response k)

(read-response wu {:keys [input]} timeout)

Read a single response from the DataInputStream of type [int length][message bytes] The message bytes are returned as a byte array Throws SocketException, Exception

TCPWritable clj protocol

-write! clj

(-write! obj tcp-client)

Write obj to the tcp client

write! clj

(write! tcp-client obj & {:keys [flush] :or {flush false}})

write-request! clj

(write-request! {:keys [output] :as client} bts)

Helper function that writes [int size in bytes][bytes] to the client and flush the request