Major Description
The current code in KafkaHealthCheck in trunk does this:
override def handleSessionEstablishmentError(error: Throwable): Unit = {
fatal("Could not establish session with zookeeper", error)
System.exit(-1)
}
thus terminating the JVM. A session establishment error shouldn't cause the JVM to terminate.
Attachments
Issue Links
- links to