Alpakka Kafka reliable delivery

Hi There,

Is there any example to replace map async with retries with reliable delivery, as described here:

https://github.com/akka/akka-samples/blob/2166558bbf9d76d7fc26c3a56984b6b741339286/akka-sample-kafka-to-sharding-scala/processor/src/main/scala/sample/shardAing/kafka/UserEventsKafkaProcessor.scala#L68

Regards,

Syed

Hi @sfali23 . I’m not aware of an example that does this from streams. There are examples in the reliable delivery docs that use the ask pattern, so I suspect it should work fine. Have you tried it?