I have written a spark job to read from kafka topic, do some processing and dump the data in avro forma