Possible race condition in NConsumer#close

[denic]

Hi,

I am using sinek's NConsumer to connect to Kafka and came across faulty behavior when trying to disconnect from the broker. It seems that 8fd1846 introduced a race condition between the disconnected event listener (when it calls NConsumer#reset) and checking the abort condition in NConsumer#_singeConsumeRecursive.

The result of this is, that the NConsumer continues trying to read messages from the disconnected node-rdkafka consumer.

{ Error: KafkaConsumer is not connected\n    at Function.createLibrdkafkaError [as create] (/home/node/event-client/node_modules/node-rdkafka/lib/error.js:261:10)\n    at /home/node/event-client/node_modules/node-rdkafka/lib/kafka-consumer.js:448:29\n  message: 'KafkaConsumer is not connected',\n  code: -172,\n  errno: -172,\n  origin: 'kafka' }

Thanks in advance!