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

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