Spark Cluster health check

[Tarun Garg]

Hi All,I am doing a POC and written a Job in java. so the architecture has 
kafka and spark.Now i want a process to notify me whenever system performance 
is getting down or in crunch of resources, like CPU or RAM. I understand 
org.apache.spark.streaming.scheduler.StreamingListener, but it has very limited 
functionality.
Can any one suggest me a way (API) to write a Spark cluster watcher.
Thanks