mx.interware.caudal.io.kafka

consumer-parameters

create-consumer

(create-consumer parameters)

create-producer

(create-producer parameters)

kafka-send

(kafka-send [topic-name parameters] & children)

Streamer function used for sending event(s) to Kafka engine.

Arguments: topic-name: Kafka topic name parameters: Kafka parameters children: Children streamer functions to be propagated

map-to-properties

(map-to-properties m)

producer-parameters

send-event

(send-event producer topic-name event)

start-processing

(start-processing channel sink)

subscribe

(subscribe consumer topic-name)