Clj-kafka 0.3.1 API documentation

Public variables and functions:

• change-topic-config
• create-topic
• delete-topic
• topic-config
• topic-exists?
• zk-client

Public variables and functions:

• consumer
• fetch-request
• latest-topic-offset
• messages
• topic-meta-data
• topic-offset

Public variables and functions:

• consumer
• create-message-stream
• create-message-streams
• default-decoder
• messages
• shutdown
• stream-seq

Public variables and functions:

• ->KafkaMessage
• as-properties
• map->KafkaMessage
• ToClojure
• with-resource

Public variables and functions:

• byte-array-serializer
• producer
• record
• send
• string-serializer

Public variables and functions:

• message
• producer
• send-message
• send-messages

Public variables and functions:

• broker-list
• brokers
• committed-offset
• controller
• offset-path
• partitions
• set-offset!
• topics