Liking cljdoc? Tell your friends :D

kafkakit.component.consumer


active-consumer-componentclj

(active-consumer-component component)

active-consumer-configclj

(active-consumer-config config)

Gets the configuration of the currently active consumer.

Gets the configuration of the currently active consumer.
raw docstring

active-consumer-keyclj

(active-consumer-key config)

Gets the key of the currently active consumer.

Gets the key of the currently active consumer.
raw docstring

consumerclj

(consumer config)

consumer-group-base-nameclj

(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-idclj

(consumer-group-id config)

rebalance-listenerclj


Subscribercljprotocol

subscribe!!clj

(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!clj

(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