crux.kafka — juxt/crux-kafka 19.12-1.6.1-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-options clj

default-producer-config clj

default-topic-config clj

doc-topic-config clj

indexing-consumer 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)

topology clj

tx-log clj

tx-record->tx-log-entry clj

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

tx-topic-config clj