tree 27fac153f3fcda5f4c2cc143d2303f2bcc054ec2
parent 439c1096df09939e3f13749722746b767f4ca753
author Terence Yim <chtyim@apache.org> 1520626886 -0800
committer Terence Yim <chtyim@apache.org> 1521155614 -0700

(TWILL-61) Fix to allow higher attempts to relaunch the app after the first attempt failed

- Delete the Kafka root zk node for the application if already exist
- Delete the AM instance zk node if already exist
- For runnables parent zk node, it is not an error if it already exist
- Enhance KafkaClient publisher / consumer to deal with Kafka cluster changes
  - When AM killed and restarted, the embedded Kafka will be running in different host and port

This closes #67 on Github.

Signed-off-by: Terence Yim <chtyim@apache.org>