onyx.kafka.helpers

Liking cljdoc? Tell your friends :D

Clojure only.

all-brokers^clj

(all-brokers zk-utils)

source

as-java^clj

(as-java opts)

source

as-properties^clj

(as-properties m)

source

assign-partitions!^clj

(assign-partitions! consumer topic-partitions)

source

beginning-end-offsets-clj^clj

(beginning-end-offsets-clj bootstrap-servers topic)

source

build-consumer^clj

(build-consumer consumer-opts key-deserializer value-deserializer)

source

build-producer^clj

(build-producer producer-opts key-serializer value-serializer)

source

byte-array-deserializer^clj

(byte-array-deserializer)

source

byte-array-serializer^clj

(byte-array-serializer)

source

consumer-record->message^clj

(consumer-record->message decompress-fn m)

source

create-topic!^clj

(create-topic! zk-addr topic-name num-partitions replication-factor)

source

end-offsets^clj

(end-offsets bootstrap-servers topic)

source

id->broker^clj

(id->broker zk-addr)

source

make-zk-client^clj

(make-zk-client zk-connection zk-config)

source

make-zk-connection^clj

(make-zk-connection zk-config)

source

make-zk-utils^clj

(make-zk-utils zk-config secure?)

source

munge-servers^clj

(munge-servers servers)

source

offsets->clj^clj

(offsets->clj end-offsets)

source

partition-info->topic-partition^clj

(partition-info->topic-partition topic part-info)

source

partitions-for-topic^clj

(partitions-for-topic consumer topic)

source

poll!^clj

(poll! consumer timeout)

source

seek-to-beginning!^clj

(seek-to-beginning! consumer topic-partitions)

source

seek-to-end!^clj

(seek-to-end! consumer topic-partitions)

source

seek-to-offset!^clj

(seek-to-offset! consumer topic-partition offset)

source

send-sync!^clj

(send-sync! producer topic part k v)

source

take-now^clj

(take-now bootstrap-servers topic decompress-fn)

(take-now bootstrap-servers topic decompress-fn timeout)

Reads whatever it can from a topic on the assumption that we've distributed work across multiple topics and another topic contained :done.

Reads whatever it can from a topic on the assumption that we've distributed
work across multiple topics and another topic contained :done.

source raw docstring

to-topic-partition^clj

(to-topic-partition tp)

source

zk-defaults^clj

source

cljdoc builds & hosts documentation for Clojure/Script libraries

Keyboard shortcuts

`Ctrl`+`k`	Jump to recent docs
`←`	Move to previous article
`→`	Move to next article
`Ctrl`+`/`	Jump to the search field

Raise an issue Browse cljdoc source Chat on Slack

× close

onyx.kafka.helpers

all-brokersclj

as-javaclj

as-propertiesclj

assign-partitions!clj

beginning-end-offsets-cljclj

build-consumerclj

build-producerclj

byte-array-deserializerclj

byte-array-serializerclj

consumer-record->messageclj

create-topic!clj

end-offsetsclj

id->brokerclj

make-zk-clientclj

make-zk-connectionclj

make-zk-utilsclj

munge-serversclj

offsets->cljclj

partition-info->topic-partitionclj

partitions-for-topicclj

poll!clj

seek-to-beginning!clj

seek-to-end!clj

seek-to-offset!clj

send-sync!clj

take-nowclj

to-topic-partitionclj

zk-defaultsclj

all-brokers^clj

as-java^clj

as-properties^clj

assign-partitions!^clj

beginning-end-offsets-clj^clj

build-consumer^clj

build-producer^clj

byte-array-deserializer^clj

byte-array-serializer^clj

consumer-record->message^clj

create-topic!^clj

end-offsets^clj

id->broker^clj

make-zk-client^clj

make-zk-connection^clj

make-zk-utils^clj

munge-servers^clj

offsets->clj^clj

partition-info->topic-partition^clj

partitions-for-topic^clj

poll!^clj

seek-to-beginning!^clj

seek-to-end!^clj

seek-to-offset!^clj

send-sync!^clj

take-now^clj

to-topic-partition^clj

zk-defaults^clj