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
)