simple_async_internal_buffer
Since it has internal buffering, it necessitates the same fix as Kafka producer.