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

Convert java objects to clojure data structures.

access-control-entry clj

(access-control-entry ace)

access-control-entry-filter clj

(access-control-entry-filter acef)

acl-binding clj

(acl-binding ab)

acl-binding-filter clj

(acl-binding-filter abf)

acl-operation clj

(acl-operation ao)

acl-permission-type clj

(acl-permission-type apt)

alter-configs-result clj

(alter-configs-result acr)

cancellable clj

(cancellable c)

config clj

(config c)

config-entry clj

(config-entry ce)

config-resource$type clj

(config-resource$type cr$t)

consumer-group-description clj

(consumer-group-description cgd)

consumer-group-listing clj

(consumer-group-listing cgl)

consumer-group-state clj

(consumer-group-state cgs)

consumer-record clj

(consumer-record cr)

create-acls-result clj

(create-acls-result car)

create-partitions-result clj

(create-partitions-result cpr)

create-topics-result clj

(create-topics-result ctr)

delete-acls-result clj

(delete-acls-result dar)

delete-acls-result$filter-result clj

(delete-acls-result$filter-result dar$fr)

delete-acls-result$filter-results clj

(delete-acls-result$filter-results dar$frs)

delete-records-result clj

(delete-records-result drr)

delete-topics-result clj

(delete-topics-result dtr)

deleted-records clj

(deleted-records dr)

describe-acls-result clj

(describe-acls-result dar)

describe-cluster-result clj

(describe-cluster-result dcr)

describe-configs-result clj

(describe-configs-result dcr)

describe-consumer-groups-result clj

(describe-consumer-groups-result dcgr)

describe-topics-result clj

(describe-topics-result dtr)

header clj

(header h)

headers clj

(headers hs)

kafka-streams$state clj

(kafka-streams$state ks$s)

key-value clj

(key-value kv)

key-value--windowed clj

(key-value--windowed kv)

key-value--ws clj

(key-value--ws kv)

key-value-iterator clj

(key-value-iterator kvi)

(key-value-iterator kvi f)

key-value-iterator--windowed clj

(key-value-iterator--windowed kvi)

list-consumer-group-offsets-result clj

(list-consumer-group-offsets-result lcgor)

list-consumer-groups-result clj

(list-consumer-groups-result lcgr)

member-assignment clj

(member-assignment ma)

member-description clj

(member-description md)

metrics clj

(metrics metrics)

node clj

(node n)

offset-and-timestamp clj

(offset-and-timestamp oat)

partition-info clj

(partition-info pi)

pattern-type clj

(pattern-type pt)

producer-record clj

(producer-record pr)

record-context clj

(record-context rc)

record-metadata clj

(record-metadata rm)

resource-pattern clj

(resource-pattern rp)

resource-pattern-filter clj

(resource-pattern-filter rpf)

resource-type clj

(resource-type rt)

streams-metadata clj

(streams-metadata sm)

timestamp-type clj

(timestamp-type tt)

topic-description clj

(topic-description td)

topic-listings clj

(topic-listings tls)

topic-partition clj

(topic-partition tp)

topic-partition->offset clj

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

topic-partition-info clj

(topic-partition-info tpo)

topology-description clj

(topology-description tp)

topology-description$global-store clj

(topology-description$global-store td$gs)

topology-description$node clj

(topology-description$node n)

topology-description$processor clj

(topology-description$processor td$p)

topology-description$source clj

(topology-description$source td$s)

topology-description$subtopology clj

(topology-description$subtopology td$s)

window clj

(window w)

window-store-iterator clj

(window-store-iterator wsi)

windowed clj

(windowed w)