diff --git a/akka-stream/src/main/scala/akka/stream/impl/Stages.scala b/akka-stream/src/main/scala/akka/stream/impl/Stages.scala
index b54dbcc918..51e712e378 100644
--- a/akka-stream/src/main/scala/akka/stream/impl/Stages.scala
+++ b/akka-stream/src/main/scala/akka/stream/impl/Stages.scala
@@ -108,7 +108,7 @@ private[stream] object Stages {
     override def withAttributes(attributes: Attributes) = copy(attributes = attributes)
   }
 
-  final case class Identity(attributes: Attributes = Attributes.name("identity")) extends StageModule {
+  final case class Identity(attributes: Attributes = identityOp) extends StageModule {
     override def withAttributes(attributes: Attributes) = copy(attributes = attributes)
   }