Error callback
==============

The error callback can be passed to the consumer of producer, it should be a
coroutine function and accepts one parameter that it is a KafkaError.

Example::

    async def error_callback(kafka_error):
        print(kafka_error)

    # Should be a wrong port
    self.producer = Producer(
        brokers="127.0.0.1:6000",
        error_callback=error_callback
    )