Have you taken a look at http://apex.apache.org/docs/apex/application_development/#exactly-once ? i.e. setting that processing mode on all the operators in the pipeline .
Join us at Apex Big Data World-San Jose <http://www.apexbigdata.com/san-jose.html>, April 4, 2017! http://www.apexbigdata.com/san-jose-register.html On 2/14/17, 12:00 PM, "Himanshu Bari" <himanshub...@gmail.com> wrote: How to ensure that the Kafka to Cassandra ingestion pipeline in Apex will guarantee exactly once processing semantics. Eg. Message was read from Kafka but apex app died before it was written successfully to Cassandra.
