firestream.core — alekcz/firestream 2.0.4

acceptable-drift clj

commit! clj

(commit! consumer offset-map)

Update offset for consumer in particular topic

consumer clj

(consumer config)

Create a consumer

expiry clj

firestream-root clj

poll! clj

(poll! consumer timeout)

Read data from subscription

producer clj

(producer config)

Create a producer

send! clj

(send! producer topic key value)

(send! producer topic key value unique)

Send new message to topic

send-queue clj

set-expiry clj

(set-expiry ms)

set-root clj

(set-root new-root)

shutdown! clj

(shutdown! producer)

Shutdown producer background thread

subscribe! clj

(subscribe! consumer topic)

Subscribe to a topic

topic-xf clj

unsubscribe! clj

(unsubscribe! consumer topic)

Unsubscribe to a topic

valid? clj

(valid? item)