My streaming job consumes data from kafka and writes them into Cassandra.
Cassandra is not stable. Streaming job crashed when it can't write data into Cassandra. Streaming job has check point. Usually, the Cassandra cluster will come back in 4 hours. Finally, I start the streaming job again, and it will start from check point and run.
Streaming job can enter a status like thread wait, not crash, and it will be notified automatically when Cassandra comes back.
Does Streaming job support this feature? I searched by Google, can't find related solutions.