要将Akka-stream中的Either类型的元素按照Right进行分组，可以使用groupBy操作符。下面是一个示例代码：

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

import scala.concurrent.Future

object AkkaStreamExample extends App {

  implicit val system: ActorSystem = ActorSystem("akka-stream-example")
  implicit val materializer: ActorMaterializer = ActorMaterializer()

  // 创建一个包含 Either 类型元素的 Source
  val source: Source[Either[String, Int], _] = Source(List(Left("error"), Right(1), Right(2), Left("error"), Right(3)))

  // 使用 groupBy 操作符将 Right 元素进行分组
  val groupedStream: Source[(Int, Source[Either[String, Int], _]), _] = source
    .groupBy(Int.MaxValue, elem => elem.fold(_ => "error", _.toString))
    .buffer(10, OverflowStrategy.backpressure) // 缓冲元素，以便处理可能的背压

  // 对每个分组进行处理
  groupedStream.runForeach { case (key, subStream) =>
    subStream.runWith(Sink.seq).map { elements =>
      println(s"Group: $key, Elements: $elements")
    }
  }

  // 等待结束
  Future(system.terminate())
}

在上面的示例中，我们创建了一个包含Either[String, Int]类型元素的Source。然后使用groupBy操作符将Right元素进行分组，并使用buffer操作符进行元素缓冲，以便处理可能的背压。最后，对每个分组进行处理并打印结果。

请注意，上述代码中的groupBy操作符使用了一个函数 elem => elem.fold(_ => "error", _.toString) 来确定分组依据。这个函数将Left元素映射为字符串"error"，将Right元素映射为其字符串表示。这样可以确保只有Right元素被分组。