diff --git a/cassandra/src/main/scala/org/apache/pekko/projection/cassandra/scaladsl/CassandraProjection.scala b/cassandra/src/main/scala/org/apache/pekko/projection/cassandra/scaladsl/CassandraProjection.scala
index 931a717a..cf3de55f 100644
--- a/cassandra/src/main/scala/org/apache/pekko/projection/cassandra/scaladsl/CassandraProjection.scala
+++ b/cassandra/src/main/scala/org/apache/pekko/projection/cassandra/scaladsl/CassandraProjection.scala
@@ -153,7 +153,7 @@ object CassandraProjection {
 
   /**
    * For testing purposes the projection offset and management tables can be created programmatically.
-   * For production it's recommended to create the table with DDL statements
+   * For production, it's recommended to create the table with DDL statements
    * before the system is started.
    */
   def createTablesIfNotExists()(implicit system: ActorSystem[_]): Future[Done] = {
diff --git a/core/src/main/scala/org/apache/pekko/projection/Projection.scala b/core/src/main/scala/org/apache/pekko/projection/Projection.scala
index 70922cf3..5b92b969 100644
--- a/core/src/main/scala/org/apache/pekko/projection/Projection.scala
+++ b/core/src/main/scala/org/apache/pekko/projection/Projection.scala
@@ -108,7 +108,7 @@ trait Projection[Envelope] {
 private[projection] object RunningProjection {
 
   /**
-   * When stopping an projection the retry mechanism is aborted via this exception.
+   * When stopping a projection the retry mechanism is aborted via this exception.
    */
   case object AbortProjectionException extends RuntimeException("Projection aborted.") with NoStackTrace