Built a feature that when my application is unable to produce messages to Kafka, it will instead produce the message to RabbitMQ.

A cronjob which is scheduled to run every 5 minutes to check the health of Kafka broker.

If Kafka is still down, it will have the queue preference set to RabbitMQ. 
If Kafka comes up, the health check will have a successful response, and queue preference is set back to Kafka.