gistfile1.txt

def sendMessage(recordToSend: Message): Future[Done] = {

  try {
    val recordToBeProduced = new ProducerRecord(SampleService.MessageTopic, Constants.Empty, message)
    val _ = producer.send(recordToBeProduced)
    logger.info("Message successfully sent!")

  } catch {
    case e: Throwable => logger.error("Failed sending message with error {}", e.getMessage)
  }
  producer.close()
  Future.successful(Done)
}