Slight refactoring of the Kafka producers.