error using Kafka with binlog router

Broken pipe error when connecting kafka to binlog router:

The sequence of the error is as follows:

1. Run the command above (cdc.py -umaxscale -pmaxscale -h127.0.0.1 -P4001 test.maxwell | cdc_kafka_producer.py --kafka-broker=10.2.9.147:9092 --kafka-topic=maxscale)
2. Get message 'value must be bytes'
3. The program will continue to run without problems (timed it to 20 mins once)
4. As soon as the insert is executed on MariaDB (insert into `test`.`maxwell` values ('89','daemon test') the following error appears: [Errno 32] Broken pipe