
12/5/2019 · Matt Howlett
What this post added
Introduces a wrapper class for the Confluent Python client to enable asyncio support, detailing the implementation of an `AIOProducer` with methods for producing messages and handling delivery callbacks. It also presents an integration example with FastAPI, showcasing how to manage the producer lifecycle and handle Kafka exceptions within web application endpoints. The post discusses strategies for out-of-band error handling and fire-and-forget scenarios, and includes load testing results using Siege.