Change the consumer code to use the batched callback method rather than blocking and timing out on single messages.
Update producer to use higher performance (don't wait so long in rd_kafka_poll).