There's no need to process the JSON twice as the Kafka producer is expected to be used with the Python CDC client which already splits the JSON with newlines.
Moved the CDC example scripts into the protocol directory and added the .py suffix. Fixed all references to these scripts.
