How to handle avro messages in CPI? [application/octet-stream]

[former_member75481]

Hello all,

I have a case to handle Apache Kafka messages encoded as application/octet-stream. It is apache avro encoding and i am wondering if there is any way how to handle it inside the CPI to see the real JSON output??

Whole input message looks like this:

�ӟ�����
����͊��
����׭��,�ӟ�����
����܎���

Is it possible to make it work using any params or groovy to change the encoding?

I am attaching sample payload (it somehow cannot be attached as file)

  
��  
��   TLALPAN
C2590CG0136S0001EOMPORTFOLIO���.TEST TESTSEN60D CORP\HAFAFAFAZM  C.P. 14999  PASFSFDASDION E INASDASDAIONES MFASFA   2SFSFA - ASFASFA ASFASFASF   ff000909-1  MX.SDASDASDS DE LA ASDSDAA>ASDASD A STA ASDASDA NO.1040-501 >ASDASD A STA TSDASD NO.1040-999���ALL DSDASDADS.A. DE C.V. SDASD DE MSDASDOOE0405 MX_111    99 MX �^U TLALPAN C.P. 14999 �����U   ��ʹ�]F1
MX003 ALSMFASFASF E ASFASFASFNES ASFASFASFABBB�����[����͊��
ɏ����̠b���������
���������
���������
��י܅��

  
��  
��   ALVARO OBREGON
C1111CG123123S23123 ASFASFASF��*ASDFAS SAF ASFASF45D CORP\AQFASSF  C.P. 01233  X12312A ASFDAFASFAFSAF CV SOFOM ENR   SDASDWRQWR0 - FSDSADA SDASDASDCA   FF012825-1  MX*WEQWEQ FE QWEQWE BWEGGSAbAV. SGDSDGSDG SDGSDG DE LA GSDGSGA 300  INT 122 bAV. ASDASDF PASEO DE LA QWEEWQ 600  INT 411 ��ALL SDAD
.N.R.D.F.AV0058 MX_405    99 MX �^I ALVARO OBREGON C.P. 011111 ���ΒK   �����]F1
MX222 XWAQDASASD INASDASDSADA SAB DE CV ASDASD ENR��Ǐ̎����͊��
݌�������
�����.���������
���������
���������

[rajeshps]

pgrunholz

sriprasadshivaramabhat

This is resolved? please share the outcome

[rajeshps]

pgrunholz

sriprasadshivaramabhat

Is this resolved? please share the outcome

[Sriprasadsbhat]

Hello Pawel,

Appreciate if you could attach sample file with AVRO Encoding.

Regards,

Sriprasad Shivaram Bhat

[former_member75481]

Hey,

I uploaded sample payload. What do you have in mind to make it work? 🙂