Failure to serialize message effectively crashes producer

Kafka producer errors out, but doesn't close transaction, so any further messages just generate 'transation already open' errors.

Realistically, need to implement validation of messages, and halt when this type of error occurs.