dev/flow.middleware.kafka.js
async function check(){
            if (broker.emitter.open <= 0) return true;
            else { 
                this.logger.warn("Event queue not empty... waiting", {queue: broker.emitter.open});
                throw "Retry";
            }
        }
async function check(){
            if (broker.emitter.open <= 0) return true;
            else { 
                this.logger.warn("Event queue not empty... waiting", {queue: broker.emitter.open});
                throw "Retry";
            }
        }
async function check ( ) { if ( broker . emitter . open <= 0 ) return true ; else { this . logger . warn ( "Event queue not empty... waiting" , { queue : broker . emitter . open } ) ; throw "Retry" ; } }
Wait for empty queue
Wait for empty queue