failure functionality added to zookeeper and kafka