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}")
}
