View definition

(AsyncProducer).AsyncClose

Defined in github.com/Shopify/sarama/async_producer.go

Description

AsyncClose triggers a shutdown of the producer, flushing any messages it may have buffered. The shutdown has completed when both the Errors and Successes channels have been closed. When calling AsyncClose, you *must* continue to read from those channels in order to drain the results of any messages in flight.