ErrorCall package:hw-kafka-client

errorCallback :: (KafkaError -> String -> IO ()) -> Callback

hw-kafka-client Kafka.Consumer Kafka.Consumer.ConsumerProperties Kafka.Producer Kafka.Producer.ProducerProperties

Add a callback for errors.

Examples

Basic usage:

'setCallback' ('errorCallback' myErrorCallback)

myErrorCallback :: 'KafkaError' -> String -> IO ()
myErrorCallback kafkaError message = print $ show kafkaError <> "|" <> message