C++ Toolchain [e.g. Visual Studio, llvm, g++]: VS code
node-rdkafka version [e.g. 2.3.3]: 2.16.0
Steps to Reproduce
If I run the consumer.consume() function and then try to disconnect with the consumer.disconnect() function, it does not disconnect and stop the program. Interestingly, when repeating the same exact process but for the producer, it stops it correctly.
node-rdkafka Configuration Settings
'rebalance_cb': function(err : LibrdKafkaError, assignment : Assignment) {
if (err.code === CODES.ERRORS.ERR__ASSIGN_PARTITIONS) {
} else if (err.code == CODES.ERRORS.ERR__REVOKE_PARTITIONS){
} else {
// We had a real error
console.error(err);
}
Environment Information
Steps to Reproduce If I run the consumer.consume() function and then try to disconnect with the consumer.disconnect() function, it does not disconnect and stop the program. Interestingly, when repeating the same exact process but for the producer, it stops it correctly.
node-rdkafka Configuration Settings 'rebalance_cb': function(err : LibrdKafkaError, assignment : Assignment) { if (err.code === CODES.ERRORS.ERR__ASSIGN_PARTITIONS) { } else if (err.code == CODES.ERRORS.ERR__REVOKE_PARTITIONS){ } else { // We had a real error console.error(err); }
Additional context