在Akka Streams中，有时会从流中收到意料之外的异常，这可能会导致整个流被中断。在这种情况下，可以使用一些技巧过滤掉异常。

我们可以使用akka.stream.scaladsl.Sink类的 recoverWithRetries操作符来捕获并处理异常。下面是一个示例代码：

import akka.actor.ActorSystem
import akka.stream.ActorMaterializer
import akka.stream.scaladsl.{Sink, Source}

import scala.concurrent.duration.Duration

object FilterExceptionExample extends App {

  implicit val system = ActorSystem("FilterExceptionExample")
  implicit val materializer = ActorMaterializer()

  def processData(data: Int): Int = {
    if (data > 5) throw new IllegalArgumentException("Data value too big")
    else data
  }

  val source = Source(1 to 10)

  val sink = Sink.foreach[Int](println)

  val flow = source.map(processData).recoverWithRetries(
    retries = 5,
    {
      case e: IllegalArgumentException =>
        println(s"Got exception: $e. Continuing...")
        Source.empty
    }
  )

  flow.runWith(sink)

  system.terminate()
}

在这个示例中，我们从1到10的范围内的数字创建了一个Source。我们使用map操作符对每个数据进行processData计算，并将结果发送到一个sink中，以便进行打印。

在这个例子中，如果processData抛出IllegalArgumentException异常，我们捕获并处理它，然后将一个空Source作为结果发送，以继续处理流中的下一个元素。

我们使用了recoverWithRetries操作符来捕获异常，并将其与模式匹配一起使用。我们定义了一个偏函数，以捕获 IllegalArgumentException 异常，并在发生异常时打印一些信息。我们传递了一个retries参数来指定我们最多要尝试处理多少次异常，以防止死循环。

最后，我们运行了flow，并将其连接到了我们的sink，以便在控制台中打印结果。

使用这种方法，我们可以轻松地处理和过滤掉流中的异常。