firestream.core — alekcz/firestream 0.1.5

channel-len clj

commit! clj

(commit! consumer topic firestream-object)

Update offset for consumer in particular topic

consumer clj

(consumer config)

Create a consumer

deserialize-data clj

(deserialize-data raw)

poll! clj

(poll! consumer buffer-size)

Read data from subscription

producer clj

(producer config)

Create a producer

root clj

send! clj

(send! producer topic data)

Send new message to topic

serialize-data clj

(serialize-data data)

shutdown! clj

(shutdown! consumer)

subscribe! clj

(subscribe! consumer topic)

Subscribe to a topic