Convert java objects to clojure data structures.
Convert java objects to clojure data structures.
(access-control-entry ace)
@ ace org.apache.kafka.common.acl.AccessControlEntry
=> {:principal
:host
Host name.
:permission
Cf. `acl-permission-type`
:operation
Cf. `acl-operation`}
@ ace org.apache.kafka.common.acl.AccessControlEntry => {:principal :host Host name. :permission Cf. `acl-permission-type` :operation Cf. `acl-operation`}
(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`}
@ 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 ab)
@ ab org.apache.kafka.common.acl.AclBinding
=> {:resource
Cf. resource
:access-control
Cf. `access-control-entry`}
@ ab org.apache.kafka.common.acl.AclBinding => {:resource Cf. `resource` :access-control Cf. `access-control-entry`}
(acl-binding-filter abf)
@ abf org.apache.kafka.common.acl.AclBindingFilter
=> {:resource
Cf. resource-filter
:access-control
Cf. `access-control-entry-filter`}
@ abf org.apache.kafka.common.acl.AclBindingFilter => {:resource Cf. `resource-filter` :access-control Cf. `access-control-entry-filter`}
(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
@ 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 apt)
@ apt org.apache.kafka.common.acl.AclPermissionType
=> One of :allow :any :deny :unknown
@ apt org.apache.kafka.common.acl.AclPermissionType => One of :allow :any :deny :unknown
(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
@ 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 c)
@ c org.apache.kafka.clients.admin.Config
=> Map of :config-name to configuration.
Cf. config-entry
@ c org.apache.kafka.clients.admin.Config => Map of :config-name to configuration. Cf. `config-entry`
(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 ?}
@ 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 cr$t)
@ cr$t org.apache.kafka.common.config.ConfigResource.Type
=> One of :brokers :topics :unknown
@ cr$t org.apache.kafka.common.config.ConfigResource.Type => One of :brokers :topics :unknown
(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.}
@ 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 crs)
@ crs org.apache.kafka.clients.consumer.ConsumerRecords
=> Map of [topic partition] to list of records.
Cf. topic-partition
consumer-record
@ crs org.apache.kafka.clients.consumer.ConsumerRecords => Map of [topic partition] to list of records. Cf. `topic-partition` `consumer-record`
(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
@ 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 cpr)
@ cpr org.apache.kafka.clients.admin.CreatePartitionsResult
=> Map of topic name to future throwing on deref if an error occured.
@ cpr org.apache.kafka.clients.admin.CreatePartitionsResult => Map of topic name to future throwing on deref if an error occured.
(create-topics-result ctr)
@ ctr org.apache.kafka.clients.admin.CreateTopicsResult
=> Map of topic-name to future throwing on deref if an error occured.
@ ctr org.apache.kafka.clients.admin.CreateTopicsResult => Map of topic-name to future throwing on deref if an error occured.
(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
@ 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 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.}
@ 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 dar$frs)
@ dar$frs org.apache.kafka.clients.admin.DeleteAclsResult.FilterResult
=> List of results.
Cf. delete-acls-result$filter-result
@ dar$frs org.apache.kafka.clients.admin.DeleteAclsResult.FilterResult => List of results. Cf. `delete-acls-result$filter-result`
(delete-topics-result dtr)
@ dtr org.apache.kafka.clients.admin.DeleteTopicsResult
=> Map of topic-name to future throwing on deref if an error occured.
@ dtr org.apache.kafka.clients.admin.DeleteTopicsResult => Map of topic-name to future throwing on deref if an error occured.
(describe-acls-result dar)
@ dar org.apache.kafka.clients.admin.DescribeAclsResult
=> Future resolving to a list of ACLs.
Cf. acl-binding
@ dar org.apache.kafka.clients.admin.DescribeAclsResult => Future resolving to a list of ACLs. Cf. `acl-binding`
(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
@ 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 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
@ 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 dtr)
@ dtr org.apache.kafka.clients.admin.DescribeTopicsResult
=> Topic descriptions.
Cf. topic-descriptions
@ dtr org.apache.kafka.clients.admin.DescribeTopicsResult => Topic descriptions. Cf. `topic-descriptions`
(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.}
@ 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 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
@ 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 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.}
@ 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 oat)
@ oat org.apache.kafka.clients.consumer.OffsetAndTimestamp
=> {:timestamp Unix timestamp of the record.
:offset
Position in the partition.}
@ oat org.apache.kafka.clients.consumer.OffsetAndTimestamp => {:timestamp Unix timestamp of the record. :offset Position in the partition.}
(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
@ 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 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.}
@ 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 r)
@ r org.apache.kafka.common.resource.Resource
=> {:name Resource name.
:type
Resource type.
Cf. `resource-type`}
@ r org.apache.kafka.common.resource.Resource => {:name Resource name. :type Resource type. Cf. `resource-type`}
(resource-filter rf)
@ rf org.apache.kafka.common.resource.ResourceFilter
=> {:name (nilable) Resource name.
:type
Resource type.
Cf. `resource-type`}
@ rf org.apache.kafka.common.resource.ResourceFilter => {:name (nilable) Resource name. :type Resource type. Cf. `resource-type`}
(resource-type rt)
@ rt org.apache.kafka.common.resource.ResourceType
=> One of :any :cluster :group :topic :transactional-id :unknown
@ rt org.apache.kafka.common.resource.ResourceType => One of :any :cluster :group :topic :transactional-id :unknown
(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`}
@ 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 tds)
@ tds List of org.apache.kafka.clients.admin.TopicDescription
=> A map of topic-name to future topic description.
Cf. topic-description
@ tds List of org.apache.kafka.clients.admin.TopicDescription => A map of topic-name to future topic description. Cf. `topic-description`
(topic-listings tls)
@ tls List of org.apache.kafka.clients.admin.TopicListing
=> A map of topic-names to topic-data.
@ 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 tp)
@ tp org.apache.kafka.common.TopicPartition
=> [topic partition]
topic Topic name.
partition Partition number.
@ tp org.apache.kafka.common.TopicPartition => [topic partition] + topic Topic name. + partition Partition number.
(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
@ 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 tp->o)
@ tp->o Map of org.apache.kafka.common.TopicPartition to offset.
=> Map of [topic partition] to offset.
Cf. topic-partition
@ tp->o Map of org.apache.kafka.common.TopicPartition to offset. => Map of [topic partition] to offset. Cf. `topic-partition`
cljdoc is a website building & hosting documentation for Clojure/Script libraries
× close