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
