Have you checked to make sure you can receive messages just using a byte array for value?
On Mon, May 16, 2016 at 12:33 PM, Ramaswamy, Muthuraman <muthuraman.ramasw...@viasat.com> wrote: > I am trying to consume AVRO formatted message through > KafkaUtils.createDirectStream. I followed the listed below example (refer > link) but the messages are not being fetched by the Stream. > > http://stackoverflow.com/questions/30339636/spark-python-avro-kafka-deserialiser > > Is there any code missing that I must add to make the above sample work. > Say, I am not sure how the confluent serializers would know the avro schema > info as it knows only the Schema Registry URL info. > > Appreciate your help. > > ~Muthu > > > --------------------------------------------------------------------- To unsubscribe, e-mail: user-unsubscr...@spark.apache.org For additional commands, e-mail: user-h...@spark.apache.org
