@Hubert Dudek​ , thanks a lot for responding.

1. When we have setup like this, if one tasks fails, it will not terminate the entire job right?
2. Since, the job is continously running as it is streaming app, is it possible to add new task to the job(while it is running)? We have around 100 kafka topics and each streaming app listens to only 1 topic.