crux.kafka — juxt/crux-kafka 19.09-1.4.0-alpha

admin-client clj

admin-wrapper clj

consume-and-index-entities clj

(consume-and-index-entities {:keys [indexer consumer pending-txs-state follower
                                    timeout tx-topic doc-topic]
                             :or {timeout 5000}})

consumer-record->value clj

(consumer-record->value record)

create-admin-client clj

(create-admin-client config)

create-consumer clj

(create-consumer config)

create-producer clj

(create-producer config)

create-topic clj

(create-topic admin-client topic num-partitions replication-factor config)

default-consumer-config clj

default-producer-config clj

default-topic-config clj

doc-topic-config clj

indexing-consumer clj

node-config clj

producer clj

seek-to-stored-offsets clj

(seek-to-stored-offsets indexer consumer partitions)

subscribe-from-stored-offsets clj

(subscribe-from-stored-offsets indexer consumer topics)

tx-log clj

tx-record->tx-log-entry clj

(tx-record->tx-log-entry record)

tx-topic-config clj

zk-status clj

(zk-status consumer-config)