firestream.core — alekcz/firestream 0.5.0

BUFFER-SIZE clj

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)

distinct-and-ordered clj

(distinct-and-ordered coll)

poll! clj

(poll! consumer timeout)

Read data from subscription

producer clj

(producer config)

Create a producer

root clj

send! clj

(send! producer topic key value)

Send new message to topic

serialize-data clj

(serialize-data topic key data)

set-root clj

(set-root new-root)

shutdown! clj

(shutdown! consumer)

subscribe! clj

(subscribe! consumer topic)

Subscribe to a topic