Adding to the previous question, is it possible to check if each record in a stream was written without any exceptions to a Cassandra Sink? I have to write the records to the next sink only if the first write is successful. So, replicating the streams before the write is not an option.
Is it possible to access the data in a stream that was written to a sink? I have a Cassandra Sink in my stream job and I have to access all the records that were written to the Cassandra sink and write it to another sink. Is there any way to do that?