I am trying to send a large CSV to kafka. The basic structure is to read a line of the CSV and zip it with the header. a = dict(zip(header, line.split(",") This then gets converted to a json wit...