Method AsyncClose

consumer.go:364–364

AsyncClose initiates a shutdown of the PartitionConsumer. This method will return immediately, after which you should continue to service the 'Messages' and 'Errors' channels until they are empty. It is required to call this function, or Close before a consumer object passes out of scope, as it will

()

	// 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.
	AsyncClose()

	// Close stops the PartitionConsumer from fetching messages. It will initiate a shutdown just like AsyncClose, drain
	// the Messages channel, harvest any errors & return them to the caller. Note that if you are continuing to service