Kafka-component 0.6.0
Released under the Eclipse Public License
A kafka component to consume from Kafka.
Installation
To install, add the following dependency to your project or build file:
[kafka-component "0.6.0"]
Topics
Namespaces
kafka-component.mock
Public variables and functions:
- ->topic-partition
- accumulate-messages
- accumulate-subscribed-messages
- add-record-in-broker-state
- add-record-to-topic
- assert-producer-not-closed
- assert-proper-record
- assign-partitions
- broker-create-topic
- broker-ensure-topic
- broker-receive-messages
- broker-save-record!
- broker-state
- buffer-size
- close-all-from
- close-mock
- committed-offsets
- committed-record-metadata
- consumer-backoff
- consumer-coordinator
- consumer-rebalance-timeout
- consumer-unsubscribe-timeout
- consumers-with-topic-overlap
- debug
- debug!
- default-mock-consumer-opts
- default-num-partitions
- fixture-restart-broker!
- get-messages
- get-offset
- goe
- goe-loop
- intersects?
- IRebalance
- logger
- max-poll-records
- mock-consumer
- mock-producer
- noop-cb
- producer-record->consumer-record
- read-offsets
- rebalance-consumers
- rebalance-participants
- rebalance-participants-timeout
- record->clj
- record->topic-partition
- records->clj
- reset-state!
- send
- send-async
- shutdown!
- standalone-mock-consumer-opts
- start!
- txfm-messages
- txfm-subscribed-messages
- with-test-broker
- with-test-producer-consumer