Details
-
Sub-task
-
Status: Open
-
Major
-
Resolution: Unresolved
-
None
-
None
-
None
Description
Tracks different failure scenarios testing around leader creating the barrier and other stream processors joining it.
A) Death of a stream processor expected to join a zookeeper barrier should regenerate a new barrier with other alive stream processors.
B) Zookeeper shutdown while waiting on the barrier should kill all stream processor.
C) Should wait until all the expected stream processors joins the zookeeper barrier.
D) Should have fixed retries on failures when creating a barrier in zookeeper.
E) Barrier.expiry(when none of the stream application joins the barrier) should trigger the leader to create a new barrier with alive processors.