View definition

(PartitionConsumer).AsyncClose

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

Description

AsyncClose initiates a shutdown of the PartitionConsumer. This method will return immediately, after which you should wait until the 'messages' and 'errors' channel are drained. It is required to call this function, or Close before a consumer object passes out of scope, as it will otherwise leak memory. You must call this before calling Close on the underlying client.