spark-rabbitmq
spark-rabbitmq copied to clipboard
Data Loss on failure
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)?