question Re: SAM error: com.hortonworks.registries.schemaregistry.serde.SerDesException: Unknown protocol id [123] received while deserializing the payload at com.hortonworks.registries.schemaregistry.serdes.avro.AvroSnapsh in Archives of Support Questions (Read Only)

SAM error: com.hortonworks.registries.schemaregistry.serde.SerDesException: Unknown protocol id [123] received while deserializing the payload at com.hortonworks.registries.schemaregistry.serdes.avro.AvroSnapsh

gkeys — Tue, 21 Apr 2026 12:21:13 GMT

Simple SAM flow: Kafka -> (Storm) filter -> Kafka

Fails at Storm, which reports: com.hortonworks.registries.schemaregistry.serde.SerDesException: Unknown protocol id [123] received while deserializing the payload at com.hortonworks.registries.schemaregistry.serdes.avro.AvroSnapsh

Wondering what could cause this. (Schema seems properly configured)

Re: SAM error: com.hortonworks.registries.schemaregistry.serde.SerDesException: Unknown protocol id [123] received while deserializing the payload at com.hortonworks.registries.schemaregistry.serdes.avro.AvroSnapsh

awoolford — Fri, 11 Aug 2017 08:42:51 GMT

I'm curious to know how the Avro data was serialized.

I suspect you're experiencing the same issue as me (see https://community.hortonworks.com/questions/114646/sam-application-unknown-protocol-id-12-received-wh.html) and possibly @Brad Penelli (see https://community.hortonworks.com/questions/114758/sam-application-kafka-source-fails.html).

Re: SAM error: com.hortonworks.registries.schemaregistry.serde.SerDesException: Unknown protocol id [123] received while deserializing the payload at com.hortonworks.registries.schemaregistry.serdes.avro.AvroSnapsh

TimothySpann — Fri, 11 Aug 2017 19:27:34 GMT

1. Make sure NiFi and SAM are the same version HDF

2. Make sure kafka message is converted properly to Avro.

3. Restart Kafka, SAM, NiFi

4. Make sure all the settings are proper.

Re: SAM error: com.hortonworks.registries.schemaregistry.serde.SerDesException: Unknown protocol id [123] received while deserializing the payload at com.hortonworks.registries.schemaregistry.serdes.avro.AvroSnapsh

TimothySpann — Tue, 15 Aug 2017 22:34:50 GMT

Make sure your queue is empty, old bad messages might be sent.

I would create a new empty queue add one checked valid message (check your avro message with avro tools) and send that.. No nulls!

Re: SAM error: com.hortonworks.registries.schemaregistry.serde.SerDesException: Unknown protocol id [123] received while deserializing the payload at com.hortonworks.registries.schemaregistry.serdes.avro.AvroSnapsh

schintalapani — Fri, 18 Aug 2017 00:00:31 GMT

@Timothy Spann @Greg Keys

This is a known issue with HDF-3.0.1 release and we fixed did a release HDF-3.0.1.1. Please find the details here

http://dev.hortonworks.com.s3.amazonaws.com/HDPDocuments/HDF3/HDF-3.0.1.1/bk_release-notes/content/ch_hdf_relnotes.html#repo-location.

1. Take a backup of existing SAM app. You can export the app to your local computer.

2. Upgrade the cluster to 3.0.1.1

3. If you have existing data in a Kafka topic that was ingested with the above bug. Make sure you create a new topic or delete the existing topic.

4. Import the SAM topology, make sure you configure the topic and other cluster details in the app.

Re: SAM error: com.hortonworks.registries.schemaregistry.serde.SerDesException: Unknown protocol id [123] received while deserializing the payload at com.hortonworks.registries.schemaregistry.serdes.avro.AvroSnapsh

gkeys — Tue, 22 Aug 2017 03:20:36 GMT

Followed instructions and it worked. Thanks @Sriharsha Chintalapani

Re: SAM error: com.hortonworks.registries.schemaregistry.serde.SerDesException: Unknown protocol id [123] received while deserializing the payload at com.hortonworks.registries.schemaregistry.serdes.avro.AvroSnapsh

roshand — Sun, 18 Aug 2019 03:16:10 GMT

@Sriharsha Chintalapani I getting the same error, cluster update didn't solve the issue.

I'm trying to consume plain CSV(roshan,22) to Streamline via NIFI(to convert CSV to AVRO). Kafka > NIFI > Kafka. From Storm I'm getting the error similar to above.

com.hortonworks.registries.schemaregistry.serde.SerDesException: Unknown protocol id [114] received while deserializing the payload at com.hortonworks.registries.schemaregistry.serdes.avro.AvroSnapsh

My Flow is as follows, One branch directly to a Kafka topic and other one to serialize and publish to kafka. After running data through the PublishKafkaRecord the output simply removes the "," (roshan,22 turns to roshan22) and the above mentioned error appears in Storm. I'm really new to this stack any help would be appreciated.

Avro schema

{
 "type": "record",
 "name": "user",
 "fields": [
  {
   "name": "name",
   "type": "string",
   "default": null
  },
  {
   "name": "age",
   "type": "string",
   "default": null
  }
 ]
}

Update Attribute Processor

Publish Kafka Record Processor

CSVReader Controller Service

AvroRecordSetWriter Controller Service

Re: SAM error: com.hortonworks.registries.schemaregistry.serde.SerDesException: Unknown protocol id [123] received while deserializing the payload at com.hortonworks.registries.schemaregistry.serdes.avro.AvroSnapsh

qwikbaba — Mon, 28 Jan 2019 18:26:44 GMT

Have you resolved your issue ?? How did you do it ??

Re: SAM error: com.hortonworks.registries.schemaregistry.serde.SerDesException: Unknown protocol id [123] received while deserializing the payload at com.hortonworks.registries.schemaregistry.serdes.avro.AvroSnapsh

qwikbaba — Mon, 28 Jan 2019 19:09:50 GMT

@Greg Keys I am having the same issue with hdf 3.3.1. I have checked the schema file and the input file as well.
I have done what was mentioned by @Sriharsha Chintalapani
Schema

{
    "namespace": "hdf.heaptrace.com",
    "type": "record",
    "name": "PatientField",
    "fields": [
    {"name": "Patient_name","type": "string"}
  ]
}

JSON data

{"Patient_name":"john"}

Please help !!!

I have converted data from json to avro and then back again as well using avro tools.