Liking cljdoc? Tell your friends :D
Clojure only.
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.
active-consumer-keyclj
(active-consumer-key config)Gets the key of the currently active consumer.
Gets the key of the currently active consumer.
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.
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