Liking cljdoc? Tell your friends :D

kafkakit.component.consumer


active-consumer-component

(active-consumer-component component)

active-consumer-config

(active-consumer-config config)

Gets the configuration of the currently active consumer.

Gets the configuration of the currently active consumer.
raw docstring

active-consumer-key

(active-consumer-key config)

Gets the key of the currently active consumer.

Gets the key of the currently active consumer.
raw docstring

consumer

(consumer config)

consumer-group-base-name

(consumer-group-base-name config)

Gets the base name for all Kafka consumer groups in this application.

Gets the base name for all Kafka consumer groups in this application.
raw docstring

consumer-group-id

(consumer-group-id config)

rebalance-listener


Subscriberprotocol

subscribe!!
(subscribe!! component topic handler)

Subscribes synchronously, polling forever while events come in. Params: component: The component. topic: String name for the message. Ex: "brands"

Subscribes synchronously, polling forever while events come in.
Params:
  component:  The component.
  topic:      String name for the message. Ex: "brands"

unsubscribe!
(unsubscribe! component)

Unsubscribe from all partitions. Params: component: The component. topic: String name for the message. Ex: "brands"

Unsubscribe from all partitions.
Params:
  component:  The component.
  topic:      String name for the message. Ex: "brands"

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

× close