As the cdc.py script outputs newline delimited JSON, there's no need to parse the JSON in the cdc_kafka_producer.py script.