search

Stratio / spark-rabbitmq

RabbitMQ Spark Streaming receiver
Apache License 2.0
208 stars 84 forks source link

Data Loss on failure #117

Open kaveh-hariri opened 6 years ago

kaveh-hariri commented 6 years ago

Hi,

If the spark streaming job fails, the messages in the buffer will be lost. What are the current workarounds? Is it possible to only send an ack back for all the messages once the entire window is done processing (writing to a durable storage)?