我试图故意阻止Kafka知道它抛出了什么异常，到目前为止，我得到了以下结果：

java.net.ConnectException: Connection refused: no further information
java.io.EOFException: null
java.nio.channels.ClosedChannelException: null

知道如何在java中捕获这些异常吗？捕捉到这些命令后，我想重新启动kafka和/或zookeeper，类似于终端中的以下命令：

kafka-server-start.sh -daemon config/server.properties
zookeeper/bin/zkServer.sh start

或者有没有其他方法可以正确处理连接错误？我在高级消费者中使用kafka0.10。