Estoy intentando enviar un mensaje a un tema de kafka en la función de captura, pero el código no funciona. aquí está mi código:

 constructor(@Inject('any') private readonly kfk: ClientKafka,private prisma: PrismaService,) {} async Send(){ try { await this.prisma.me.create({ data: { Message:"test", }, }); } catch (e) { await this.kfk.emit('Notification.back', { Me:"test", }) } }

El mensaje es de tipo cadena. Cuando intento enviar un mensaje que no es una cadena a la base de datos, tendrá un error y debería ejecutar el código en la captura. Sin embargo, this.kfk.emit no funciona.

Por favor ayuda