Pamela Ramírez Arrunátegui

Hola a todos! Me encuentro implementando kafka con nestjs, usando kafkajs, y al configurar un consumer, al parecer nest no está recibiendo correctamente un mensaje cuando proviene de un topic generado con ksqldb (stream), me trae el mensaje cortado y con caracteres extraños. Ya probé cambiando de topic por uno regular (generado directamente por un producer) y todo bien aquí, el error solo pasa cuando se trata de un stream. Alguien que tenga un indicio del error? A continuación parte del mensaje que recibo: {"��\x016�\x01j�\x01,690980188348\x01���\x01��\x01z�\x01)&V�\x01\x18dropoff\x01�)�\x00S=�!�2�\x01\x04"+%�\x00Av�\x01\x002=�!� @$@gmail.comAA9�,233174246858!�PAUTO_ASSIGNED":true,"\r\x10�R_TIME":