diff --git a/migrator/src/main/scala/akka/persistence/jdbc/migrator/JournalMigrator.scala b/migrator/src/main/scala/akka/persistence/jdbc/migrator/JournalMigrator.scala index 59243358a..605f0e491 100644 --- a/migrator/src/main/scala/akka/persistence/jdbc/migrator/JournalMigrator.scala +++ b/migrator/src/main/scala/akka/persistence/jdbc/migrator/JournalMigrator.scala @@ -141,7 +141,11 @@ final case class JournalMigrator(profile: JdbcProfile)(implicit system: ActorSys val tagInserts = newJournalQueries.TagTable ++= tags .map(tag => - TagRow(None, Some(journalSerializedRow.persistenceId), Some(journalSerializedRow.sequenceNumber), tag)) + TagRow( + Some(journalSerializedRow.ordering), // legacy tag key enabled by default. + Some(journalSerializedRow.persistenceId), + Some(journalSerializedRow.sequenceNumber), + tag)) .toSeq journalInsert.flatMap(_ => tagInserts.asInstanceOf[DBIO[Unit]])