kafkakit.component.consumer — bridg/kafkakit 0.5.0

active-consumer-component clj

(active-consumer-component component)

active-consumer-config clj

(active-consumer-config config)

Gets the configuration of the currently active consumer.

active-consumer-key clj

(active-consumer-key config)

Gets the key of the currently active consumer.

consumer clj

(consumer config)

consumer-group-base-name clj

(consumer-group-base-name config)

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

consumer-group-id clj

(consumer-group-id config)

rebalance-listener clj

Subscriber clj protocol

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"

unsubscribe! clj

(unsubscribe! component)

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