Is this strange or wierd? I had no Kafka or Zookeeper running on my local machine and I was expecting an exception, but for some strange reason, I do not see any errors:
try { logger.info(s"kafka producer obtained is ${producer}") producer.send( new ProducerRecord[String, String](producerConfig.topic, jsonMessage) ) } catch { case x: Throwable => logger.error(s"shit happened ******* ${x.getMessage}") }