I am working on ingesting realtime data from apache kafka topic. The data is stored in Avro format with