Liking cljdoc? Tell your friends :D

milena.interop.clj

Convert java objects to clojure data structures.

Convert java objects to clojure data structures.
raw docstring

-topology-description$node--namesclj

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

access-control-entryclj

(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`}
raw docstring

access-control-entry-filterclj

(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`}
raw docstring

acl-bindingclj

(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`}
raw docstring

acl-binding-filterclj

(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`}
raw docstring

acl-operationclj

(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
raw docstring

acl-permission-typeclj

(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
raw docstring

alter-configs-resultclj

(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`
raw docstring

configclj

(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`
raw docstring

config-entryclj

(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 ?}
raw docstring

config-resource$typeclj

(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
raw docstring

consumer-recordclj

(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.}
raw docstring

consumer-records-by-partitionsclj

(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`
raw docstring

create-acls-resultclj

(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`
raw docstring

create-partitions-resultclj

(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.
raw docstring

create-topics-resultclj

(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.
raw docstring

delete-acls-resultclj

(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`
raw docstring

delete-acls-result$filter-resultclj

(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.}
raw docstring

delete-acls-result$filter-resultsclj

(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`
raw docstring

delete-topics-resultclj

(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.
raw docstring

describe-acls-resultclj

(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`
raw docstring

describe-cluster-resultclj

(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`
raw docstring

describe-configs-resultclj

(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`
raw docstring

describe-topics-resultclj

(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`
raw docstring

kafka-streams$stateclj

(kafka-streams$state ks$s)
raw docstring

key-valueclj

(key-value kv)
raw docstring

key-value--windowedclj

(key-value--windowed kv)
raw docstring

key-value--wsclj

(key-value--ws kv)
raw docstring

key-value-iteratorclj

(key-value-iterator kvi)
(key-value-iterator kvi f)
raw docstring

key-value-iterator--windowedclj

(key-value-iterator--windowed kvi)
raw docstring

metric-nameclj

(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.}
raw docstring

metricsclj

(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`
raw docstring

nodeclj

(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.}
raw docstring

offset-and-timestampclj

(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.}
raw docstring

partition-infoclj

(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`
raw docstring

record-metadataclj

(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.}
raw docstring

resourceclj

(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`}
raw docstring

resource-filterclj

(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`}
raw docstring

resource-typeclj

(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
raw docstring

topic-descriptionclj

(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`}
raw docstring

topic-descriptionsclj

(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`
raw docstring

topic-listingsclj

(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?}
@ tls
  List of org.apache.kafka.clients.admin.TopicListing

=> A map of topic-names to topic-data.
   
   + topic-data
     {:internal?
       Is this topic internal?}
raw docstring

topic-partitionclj

(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.
raw docstring

topic-partition-infoclj

(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`
raw docstring

topic-partition-to-offsetclj

(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`
raw docstring

topology-descriptionclj

(topology-description tp)
raw docstring

topology-description$global-storeclj

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

topology-description$nodeclj

(topology-description$node n)
raw docstring

topology-description$processorclj

(topology-description$processor td$p)
raw docstring

topology-description$sourceclj

(topology-description$source td$s)
raw docstring

topology-description$subtopologyclj

(topology-description$subtopology td$s)
raw docstring

windowclj

(window w)
raw docstring

window-store-iteratorclj

(window-store-iterator wsi)
raw docstring

windowedclj

(windowed w)
raw docstring

cljdoc is a website building & hosting documentation for Clojure/Script libraries

× close