getProducer().then((producer) => {

        // Send the payload to Kafka
        let d = q.defer();
        producer.send(_retryPayloads, d.makeNodeResolver());