dvlopt.kafka.-interop.java — dvlopt/kafka 1.3.1

Convert clojure data structures to java objects.

-*store-number clj

access-control-entry clj

(access-control-entry options)

access-control-entry-filter clj

(access-control-entry-filter options)

acl-binding clj

(acl-binding options)

acl-binding-filter clj

(acl-binding-filter options)

acl-operation clj

(acl-operation kw)

acl-permission-type clj

(acl-permission-type kw)

admin-timeout clj

(admin-timeout options)

aggregator clj

(aggregator f)

alter-configs-options clj

(alter-configs-options options)

callback clj

(callback f)

config clj

(config entries)

config-entry clj

(config-entry [kw value])

(config-entry kw value)

config-resource$type clj

(config-resource$type kw)

config-resources clj

(config-resources resources)

consumed clj

(consumed options)

consumer-rebalance-listener clj

(consumer-rebalance-listener f)

consumer-record clj

(consumer-record record)

create-acls-options clj

(create-acls-options options)

create-partitions-options clj

(create-partitions-options options)

create-topics-options clj

(create-topics-options options)

delete-acls-options clj

(delete-acls-options options)

delete-records-options clj

(delete-records-options options)

delete-topics-options clj

(delete-topics-options options)

describe-acls-options clj

(describe-acls-options options)

describe-cluster-options clj

(describe-cluster-options options)

describe-configs-options clj

(describe-configs-options options)

describe-consumer-groups-options clj

(describe-consumer-groups-options options)

describe-topics-options clj

(describe-topics-options options)

duration clj

(duration [interval unit])

extended-deserializer clj

(extended-deserializer kw-or-f)

extended-serializer clj

(extended-serializer kw-or-f)

foreach-action clj

(foreach-action f)

grouped clj

(grouped options)

header clj

(header [k v])

(header k v)

headers clj

(headers)

(headers headers)

initializer clj

(initializer f)

join-windows clj

(join-windows interval options)

joined clj

(joined options)

kafka-streams$state-listener clj

(kafka-streams$state-listener f)

key-value clj

(key-value [k v])

(key-value k v)

key-value-bytes-store-supplier--in-memory clj

(key-value-bytes-store-supplier--in-memory store-name)

key-value-bytes-store-supplier--lru-map clj

(key-value-bytes-store-supplier--lru-map store-name options)

key-value-bytes-store-supplier--regular clj

(key-value-bytes-store-supplier--regular store-name)

key-value-mapper clj

(key-value-mapper f)

key-value-mapper--flat clj

(key-value-mapper--flat f)

key-value-mapper--raw clj

(key-value-mapper--raw f)

list-consumer-group-offsets-options clj

(list-consumer-group-offsets-options options)

list-consumer-groups-options clj

(list-consumer-groups-options {:as options :keys [timeout]})

list-topics-options clj

(list-topics-options options)

materialized--by-name clj

(materialized--by-name options)

materialized--kv clj

(materialized--kv options)

merger clj

(merger f)

new-partitions clj

(new-partitions options)

new-topic clj

(new-topic topic options)

offset-commit-callback clj

(offset-commit-callback f)

offset-reset-strategy clj

(offset-reset-strategy kw)

pattern-type clj

(pattern-type kw)

predicate clj

(predicate pred)

processor clj

(processor options)

processor-supplier clj

(processor-supplier x)

produced clj

(produced options)

producer-record clj

(producer-record record)

properties clj

(properties hmap)

punctuation-type clj

(punctuation-type time-type)

punctuator clj

(punctuator f)

records-to-delete clj

(records-to-delete offset)

reducer clj

(reducer seed)

resource-pattern clj

(resource-pattern options)

resource-pattern-filter clj

(resource-pattern-filter options)

resource-type clj

(resource-type kw)

serde clj

(serde serializer deserializer)

serde-key clj

(serde-key options)

serde-value clj

(serde-value options)

serialized clj

(serialized options)

session-bytes-store-supplier clj

(session-bytes-store-supplier store-name options)

session-windows clj

(session-windows interval options)

store-builder clj

(store-builder options)

stream-partitioner clj

(stream-partitioner f)

streams-config clj

(streams-config application-id options)

thread$uncaught-exception-handler clj

(thread$uncaught-exception-handler f)

time-unit clj

(time-unit unit)

time-windows clj

(time-windows interval options)

timestamp-extractor clj

(timestamp-extractor f)

timestamp-type clj

(timestamp-type kw)

to-milliseconds clj

(to-milliseconds [interval unit])

topic-name-extractor clj

(topic-name-extractor f)

topic-partition clj

(topic-partition [topic partition])

(topic-partition topic partition)

topic-partition->offset clj

(topic-partition->offset topic-partition->offset)

topic-partition->offset-and-metadata clj

(topic-partition->offset-and-metadata tp->o)

topology$auto-offset-reset clj

(topology$auto-offset-reset offset-reset)

transformer clj

(transformer options)

transformer-supplier clj

(transformer-supplier x)

value-joiner clj

(value-joiner f)

value-mapper-with-key clj

(value-mapper-with-key f)

value-transformer-with-key clj

(value-transformer-with-key options)

value-transformer-with-key-supplier clj

(value-transformer-with-key-supplier x)

window clj

(window from-timestamp to-timestamp)

window-bytes-store-supplier clj

(window-bytes-store-supplier store-name options)

windowed clj

(windowed k from-timestamp to-timestamp)