onyx.kafka.helpers — org.onyxplatform/onyx-kafka 0.14.4.1-SNAPSHOT

all-brokers clj

(all-brokers zk-utils)

as-java clj

(as-java opts)

as-properties clj

(as-properties m)

assign-partitions! clj

(assign-partitions! consumer topic-partitions)

beginning-end-offsets-clj clj

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

build-consumer clj

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

build-producer clj

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

byte-array-deserializer clj

(byte-array-deserializer)

byte-array-serializer clj

(byte-array-serializer)

consumer-record->message clj

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

create-topic! clj

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

end-offsets clj

(end-offsets bootstrap-servers topic)

id->broker clj

(id->broker zk-addr)

make-zk-client clj

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

make-zk-connection clj

(make-zk-connection zk-config)

make-zk-utils clj

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

munge-servers clj

(munge-servers servers)

offsets->clj clj

(offsets->clj end-offsets)

partition-info->topic-partition clj

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

partitions-for-topic clj

(partitions-for-topic consumer topic)

poll! clj

(poll! consumer timeout)

seek-to-beginning! clj

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

seek-to-end! clj

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

seek-to-offset! clj

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

send-sync! clj

(send-sync! producer topic part k v)

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.

to-topic-partition clj

(to-topic-partition tp)

zk-defaults clj