I have a akka stream , which basically listen to Rabbitmq and process the message. So i made the stream is running for-ever. But when i watched closely, its leading to memory leak. Below is the snippet
// Stream Run
val amqpMessageGraph = amqpSourceContext.via(messageProcessFlow).via(amqpSinkAsFlow).asSource.via(dbDocumentFlow).via(insertAndAckFlow).to(Sink.ignore)*
val withCustomSupervision = *
- Is it really necessary to stop the stream when there is no flow of data for x amount of time?
- By improve anything in the stream flow, i can avoid the memory leak ?