Guozhang, I am using 0.10.0.0. Could the below log be the cause?
16/09/14 17:24:35 WARN ConsumerConfig: The configuration schema.registry.url = http://192.168.50.6: <http://192.168.50.6:8081/>8081 was supplied but isn't a known config. 16/09/14 17:24:35 INFO AppInfoParser: Kafka version : 0.10.0.0 16/09/14 17:24:35 INFO AppInfoParser: Kafka commitId : b8642491e78c5a13 Walter On Wed, Sep 14, 2016 at 8:11 PM, Guozhang Wang <wangg...@gmail.com> wrote: > Hello Walter, > > Which version of Kafka were you using? > > I ask this because there was a bug causing the serde passed through config > to NOT being configured when constructed: > https://issues.apache.org/jira/browse/KAFKA-3639 > > > Which is fixed in the 0.10.0.0 release, which means you will only hit it if > you are using the tech-preview release version. > > > Guozhang > > > On Wed, Sep 14, 2016 at 11:10 AM, Walter rakoff <walter.rak...@gmail.com> > wrote: > > > Hello, > > > > I get the below exception when deserilaizing avro records > > using KafkaAvroDeserializer. > > > > 16/09/14 17:24:39 INFO StreamThread: Stream thread shutdown complete > > [StreamThread-1] > > Exception in thread "StreamThread-1" > > org.apache.kafka.common.errors.SerializationException: > > Error deserializing Avro message for id 4 > > Caused by: java.lang.NullPointerException > > at io.confluent.kafka.serializers.AbstractKafkaAvroDeserializer. > > deserialize(AbstractKafkaAvroDeserializer.java:120) > > at io.confluent.kafka.serializers.AbstractKafkaAvroDeserializer. > > deserialize(AbstractKafkaAvroDeserializer.java:92) > > > > I can confirm that schema registry URL is accessible and > url/schemas/ids/4 > > does return valid schema. > > May be some initialization didn't happen correctly? > > > > props.put(AbstractKafkaAvroSerDeConfig.SCHEMA_REGISTRY_URL_CONFIG, " > > 192.168.50.6:8081") > > props.put(StreamsConfig.KEY_SERDE_CLASS_CONFIG, > > Serdes.Long.getClass.getName) > > props.put(StreamsConfig.VALUE_SERDE_CLASS_CONFIG, classOf[ > > GenericAvroSerdeWithSchemaRegistry]) > > > > GenericAvroSerdeWithSchemaRegistry code --> https://www.dropbox.com/s/ > > y471k9nj94tlxro/avro_serde.txt?dl=0 > > > > Walter > > > > > > -- > -- Guozhang >
