"Wire format is invalid: Error: illegal buffer"

General
1

Hello Everyone,

I am trying to decode/deserialize a Kafka message using kafka consumer. The serialization process at the producer side is functioning well but while trying to decode the message, i am getting "Wire format is invalid: Error: illegal buffer" error.

I could not see many options in kafka consumer to change further options. I have used the same .proto files at producer and consumer nodes. My .proto file looks like below:

syntax = "proto3";

package jspb.test;

option java_package = "com.google.apps.jspb.proto";
option java_multiple_files = true;

// legacy data, must be nested

message data {
required string company = 1;
required string street = 2;
required string country = 3;
required string state = 4;
required string companyType = 5;
}

Can anyone please suggest me a solution or help me find out a problem?
Any help would be really appreciated. Thank you very much.

Best Regards,

2

Hi and welcome to the forum. However, this looks like a Kafka problem rather than a Node-RED one? Maybe there is a Kafka support forum?

3

Hello,
Thank your for your response. I just solved the issue. I had to convert the message received from kafka consumer to "Buffer Binary" message format using a "function" node before passing the message to protobuf decode node.

Best Regards,

1 Like
4

This topic was automatically closed 14 days after the last reply. New replies are no longer allowed.