Jose Ignacio Gil Jaldo

I created https://github.com/westoque/phantomjs.rb/pull/14 that should fix this issue.

Yes, that part is clearly understood, but the subscriber works with any arbitrary number of partitions, it gets and uses those assigned to it by the broker, but it consumes...

> Also just curious as you mention the number of partitions changing while the consumer runs. In your use-case, do the partition count change frequently? Not really, just saying it...

> Looking at your code, I see no consumer group provided. Therefore the consumer assignment protocol is used, and acking a record doesn't really do anything useful It was just...

Hey @sarkarshuvojit I created https://github.com/ThreeDotsLabs/watermill-kafka/pull/29 to try and implement a few different consumption methods, feel free to have a look.

Sorry, I just noticed https://github.com/sidorares/node-mysql2/issues/2080 and I believe they could be related, my reproduction seems to work correctly with 2.3.0 (which is the one that @rogerho1224 was using and worked...

No worries @sidorares if it helps, it might be intimately related to #2080 since I can confirm that using 2.3.0 fixed the issue for me.

I'm not sure if it's GC related, (not a node internals expert,but) I ran my reproduction with --trace-gc and the gc logs stop right with the "Done" message.

Mine is Ubuntu x86_64. But a colleague of mine has the same issue with similar effects with M1.

Just tested with --noopt and it finished successfully almost immediately.