Documentation

sendStreamKafka :: Store alpha => String -> KafkaConfig -> Metrics -> Stream alpha -> IO () Source #

runKafkaConsumer :: Store alpha => String -> KafkaConfig -> Metrics -> InChan (Event alpha) -> IO () Source #