diff --git a/lib/kafkaClient.js b/lib/kafkaClient.js index 98164574..6fad8df8 100644 --- a/lib/kafkaClient.js +++ b/lib/kafkaClient.js @@ -1252,7 +1252,8 @@ KafkaClient.prototype.sendFetchRequest = function ( ) { logger.error( 'ignoring message due to it being from an old group - memberId: ' + memberId, - '!=' + consumer.memberId + ' - generationId: ' + generationId + '!=' + consumer.generationId + '!=' + consumer.memberId + ' - generationId: ' + generationId + '!=' + consumer.generationId, + ' or consumer state with closing: ' + consumer.closing + ' rebalancing: ' + consumer.rebalancing + ' connecting: ' + consumer.connecting ); return false; }