milena.interop.clj — dvlopt/milena 0.4.0-alpha3

Convert java objects to clojure data structures.

-topology-description$node--names clj

(-topology-description$node--names nodes)

access-control-entry clj

(access-control-entry ace)

@ ace org.apache.kafka.common.acl.AccessControlEntry

=> {:principal

:host
 Host name.

:permission
 Cf. `acl-permission-type`

:operation
 Cf. `acl-operation`}

access-control-entry-filter clj

(access-control-entry-filter acef)

@ acef org.apache.kafka.common.acl.AccessControlEntryFilter

=> {:principal (nilable)

:host (nilable)
 Host name or nil.

:permission
 Cf. `acl-permission-type`

:operation
 Cf. `acl-operation`}

acl-binding clj

(acl-binding ab)

@ ab org.apache.kafka.common.acl.AclBinding

=> {:resource Cf. resource

:access-control
 Cf. `access-control-entry`}

acl-binding-filter clj

(acl-binding-filter abf)

@ abf org.apache.kafka.common.acl.AclBindingFilter

=> {:resource Cf. resource-filter

:access-control
 Cf. `access-control-entry-filter`}

acl-operation clj

(acl-operation ao)

@ ao org.apache.kafka.common.acl.AclOperation

=> One of :all :alter :alter-config :any :cluster-action :create :delete :describe :describe-config :idempotent-write :read :unknown :write

acl-permission-type clj

(acl-permission-type apt)

@ apt org.apache.kafka.common.acl.AclPermissionType

=> One of :allow :any :deny :unknown

alter-configs-result clj

(alter-configs-result acr)

@ acr org.apache.kafka.clients.admin.AlterConfigsResult

=> Map of resource type to map of resource name to future throwing on deref if an error occured. Cf. config-resource$type

config clj

(config c)

@ c org.apache.kafka.clients.admin.Config

=> Map of :config-name to configuration. Cf. config-entry

config-entry clj

(config-entry ce)

@ ce org.apache.kafka.clients.admin.ConfigEntry

=> {:name Name of the configuration.

:value
 Value for this configuration.

:default?
 Is this the default value ?

:read-only?
 Is this configuration read only ?

:sensitive?
 Is the value sensitive and ought to be hidden ?}

config-resource$type clj

(config-resource$type cr$t)

@ cr$t org.apache.kafka.common.config.ConfigResource.Type

=> One of :brokers :topics :unknown

consumer-record clj

(consumer-record cr)

@ cr org.apache.kafka.clients.consumer.ConsumerRecord

=> {:topic Topic name.

:partition
 Partition number.

:offset
 Record offset.

:timestamp
 Unix timestamp.

:key
 Deserialized key.

:value
 Deserialized value.}

consumer-records-by-partitions clj

(consumer-records-by-partitions crs)

@ crs org.apache.kafka.clients.consumer.ConsumerRecords

=> Map of [topic partition] to list of records. Cf. topic-partition consumer-record

create-acls-result clj

(create-acls-result car)

@ car org.apache.kafka.clients.admin.CreateAclsResult

=> Map of ACLs to future throwing on deref if an error occured. Cf. acl-binding

create-partitions-result clj

(create-partitions-result cpr)

@ cpr org.apache.kafka.clients.admin.CreatePartitionsResult

=> Map of topic name to future throwing on deref if an error occured.

create-topics-result clj

(create-topics-result ctr)

@ ctr org.apache.kafka.clients.admin.CreateTopicsResult

=> Map of topic-name to future throwing on deref if an error occured.

delete-acls-result clj

(delete-acls-result dar)

@ dar org.apache.kafka.clients.admin.DeleteAclsResult

=> Map of ACL filters to futures resolving to results. Cf. delete-acls-result$filter-result

delete-acls-result$filter-result clj

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

@ dar$fr org.apache.kafka.clients.admin.DeleteAclsResult.FilterResult

=> {:exception (nilable) Exception or nil if no error occured.

:acl (nilable)
 ACL of nil if an error occured.}

delete-acls-result$filter-results clj

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

@ dar$frs org.apache.kafka.clients.admin.DeleteAclsResult.FilterResult

=> List of results. Cf. delete-acls-result$filter-result

delete-topics-result clj

(delete-topics-result dtr)

@ dtr org.apache.kafka.clients.admin.DeleteTopicsResult

=> Map of topic-name to future throwing on deref if an error occured.

describe-acls-result clj

(describe-acls-result dar)

@ dar org.apache.kafka.clients.admin.DescribeAclsResult

=> Future resolving to a list of ACLs. Cf. acl-binding

describe-cluster-result clj

(describe-cluster-result dcr)

@ dcr org.apache.kafka.clients.admin.DescribeClusterResult

=> {:id Future, the id of the cluster.

:nodes
 Future, a list of the cluster's nodes.

:controller
 Future, the controller node.}

Cf. node

describe-configs-result clj

(describe-configs-result dcr)

@ dcr org.apache.kafka.clients.admin.DescribeConfigsResult

=> Map of resource type to map of ressource name to future configuration map. Cf. config-resource$type

describe-topics-result clj

(describe-topics-result dtr)

@ dtr org.apache.kafka.clients.admin.DescribeTopicsResult

=> Topic descriptions.

Cf. topic-descriptions

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)

metric-name clj

(metric-name m-n)

@ m-n org.apache.kafka.common.MetricName

=> {:group Logical group name of the metrics to which this metric belongs.

:name
 String name of the metric.

:description
 String description for human consumption.

:tags
 Map of kws to strings, additional key-values.}

metrics clj

(metrics metrics)

@ metrics Metrics about a producer or a consumer.

=> Map of :metric-group/metric-name to data.

• data {:description String description for human consumption.

  :tags Map of kws to strings, additional key-values.

  :value Numerical value of the metric.}

Cf. metric-name

node clj

(node n)

@ n org.apache.kafka.common.Node

=> {:host Host name for this node.

:port
 The port this node is listening on.

:rack (nilable)
 The name of the rack this node is on.

:id
 The numerical ID of this node.}

offset-and-timestamp clj

(offset-and-timestamp oat)

@ oat org.apache.kafka.clients.consumer.OffsetAndTimestamp

=> {:timestamp Unix timestamp of the record.

:offset
 Position in the partition.}

partition-info clj

(partition-info pi)

@ p-i org.apache.kafka.common.PartitionInfo

=> {:topic Topic name.

 :partition
  Partition number.

 :leader
  Leader node of the partition of nil if none.

 :replicas
  List of replicating nodes for this partition, and which are in sync.}

Cf. node

record-metadata clj

(record-metadata rm)

@ rm org.apache.kafka.clients.producer.RecordMetadata

=> {:topic Name of the topic the record was appended to.

:?partition (nilable)
 Partition number of the topic or nil if unknown.

:timestamp
 Unix timestamp of the new record.

:offset
 Offset of the new record.}

resource clj

(resource r)

@ r org.apache.kafka.common.resource.Resource

=> {:name Resource name.

:type
 Resource type.
 Cf. `resource-type`}

resource-filter clj

(resource-filter rf)

@ rf org.apache.kafka.common.resource.ResourceFilter

=> {:name (nilable) Resource name.

:type
 Resource type.
 Cf. `resource-type`}

resource-type clj

(resource-type rt)

@ rt org.apache.kafka.common.resource.ResourceType

=> One of :any :cluster :group :topic :transactional-id :unknown

topic-description clj

(topic-description td)

@ td org.apache.kafka.clients.admin.TopicDescription

=> {:internal? Is this topic internal ?

:partitions
 A list of topic-partitions sorted by partition number.

 Cf. `topic-partition-info`}

topic-descriptions clj

(topic-descriptions tds)

@ tds List of org.apache.kafka.clients.admin.TopicDescription

=> A map of topic-name to future topic description.

Cf. topic-description

topic-listings clj

(topic-listings tls)

@ tls List of org.apache.kafka.clients.admin.TopicListing

=> A map of topic-names to topic-data.

• topic-data {:internal? Is this topic internal?}

topic-partition clj

(topic-partition tp)

@ tp org.apache.kafka.common.TopicPartition

=> [topic partition]

• topic Topic name.

• partition Partition number.

topic-partition-info clj

(topic-partition-info tpo)

@ tpo org.apache.kafka.common.TopicPartitionInfo

=> {:partition Partition number.

:leader
 Leader node of the partition or nil if none.

:replicas
 List of replicating nodes for this partition, and which are in sync.}

Cf. node

topic-partition-to-offset clj

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

@ tp->o Map of org.apache.kafka.common.TopicPartition to offset.

=> Map of [topic partition] to offset. Cf. topic-partition

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)