fix: minor fix of debug log in JdbcOffsetStore (#1312)

akka · Feb 12, 2025 · a7808ab · a7808ab
1 parent adbfd31
commit a7808ab
Showing 1 changed file with 1 addition and 4 deletions.
diff --git a/akka-projection-jdbc/src/main/scala/akka/projection/jdbc/internal/JdbcOffsetStore.scala b/akka-projection-jdbc/src/main/scala/akka/projection/jdbc/internal/JdbcOffsetStore.scala
@@ -80,10 +80,7 @@ class JdbcOffsetStore[S <: JdbcSession](
 
   def clearOffset(projectionId: ProjectionId): Future[Done] = {
     withConnection(jdbcSessionFactory) { conn =>
-      logger.debug(
-        "clearing offset for [{}], using connection id [{}], using connection id [{}]",
-        projectionId,
-        System.identityHashCode(conn))
+      logger.debug("clearing offset for [{}], using connection id [{}]", projectionId, System.identityHashCode(conn))
       tryWithResource(conn.prepareStatement(settings.dialect.clearOffsetStatement)) { stmt =>
         stmt.setString(1, projectionId.name)
         stmt.setString(2, projectionId.key)