Support Questions
Find answers, ask questions, and share your expertise
Announcements
Alert: Welcome to the Unified Cloudera Community. Former HCC members be sure to read and learn how to activate your account here.

Issue with storm kafka spout

Issue with storm kafka spout

New Contributor

Hi,

Please your help with the following issue:

I'm loading a xml file from nifi to kafka using xml split and publishKafka_0_10 processors. Also I create a new schema in the schema registry and deploy a new application in SAM that take the data from kafka to create a .txt file using a HDFS sink.

When I`m going to storm UI, I see that the spouts (kafka) have the following error:

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

Please your help with this issue.

Actually, we have two nodes, in the first one we have the following applications:

Ambari - Nifi and kafka

In the second one we have this applications:

Schema registry - SAM - Hive - HDFS

Our HDF version is 3.0.2.0, for that reason we dismiss this HCC: https://community.hortonworks.com/questions/121234/sam-error-comhortonworksregistriesschemaregistrys...

Thanks

Don't have an account?
Coming from Hortonworks? Activate your account here