Cleaned up Kafka code and changed the generic producer and consumer to
publish and consume from a single topic per db/table instead of 3 (insert,
update, and delet).