kmonitor.ts

kmonitor.ts

// kmonitor.ts

import { Injectable } from "@nestjs/common";
import { Ctx, KafkaContext } from "@nestjs/microservices";

@Injectable()
export class kMonitor {
    constructor(@Ctx() context: KafkaContext) {
        context.getConsumer().on('consumer.rebalancing', (ev) => {
            console.log(ev)
        })
    }   
}