How to correct disconnect multiple consumers? about kafkajs HOT 5 CLOSED

const consumers = [...]
await Promise.all(consumers)
console.log('disconnected')

  /**
   * @return {Promise}
   */
  const disconnect = async () => {
    try {
      if (runner) {
        await runner.stop()
        logger.debug('consumer has stopped, disconnecting', { groupId })
      }
      await cluster.disconnect()
    } catch (e) {}
    logger.info('Stopped', { groupId })
}

	/**
	 * Service stopped lifecycle event handler
	 */
	async stopped() {
        
        await Promise.all(this.subscriptions.map(async (subscription) => {
            try {
                await subscription.consumer.disconnect();
                this.logger.info(`Consumer for subscription ${subscription.id} stopped`);

            } catch(err) {
                this.logger.warn(`Stopping consumer for subscription ${subscription.id} failed`);
            }
            Promise.resolve();
        }));
        this.logger.info(`All consumers disconnected`);

    }