diff --git a/pkg/cluster/streams.go b/pkg/cluster/streams.go
index a6d498d83..a1a1b4d4a 100644
--- a/pkg/cluster/streams.go
+++ b/pkg/cluster/streams.go
@@ -316,7 +316,7 @@ func (c *Cluster) syncStreams() error {
 		dbName := slots[publication]["database"]
 		err = c.syncPublication(publication, dbName, tables)
 		if err != nil {
-			c.logger.Warningf("could not sync publication %q in database %d: %v", publication, dbName, err)
+			c.logger.Warningf("could not sync publication %q in database %q: %v", publication, dbName, err)
 		}
 	}