swift-kafka-client
swift-kafka-client copied to clipboard
Add `librdkafka` error callback
See: rd_kafka_conf_set_error_cb()
Expected behaviour
- log non-fatal errors to our
loggerobject - change state of our
KafkaProducer / KafkaConsumerwhen fatal error occurs (needs more investigation, idea: shutdown on fatal error)