Fix typos

aartigao · Oct 28, 2023 · 170f829 · 170f829
1 parent 15d32d9
commit 170f829
Show file tree

Hide file tree

Showing 5 changed files with 5 additions and 5 deletions.
diff --git a/modules/core/src/main/scala/fs2/kafka/ConsumerSettings.scala b/modules/core/src/main/scala/fs2/kafka/ConsumerSettings.scala
@@ -353,7 +353,7 @@ sealed abstract class ConsumerSettings[F[_], K, V] {
     * You can use [[withMaxPollRecords]] to control the `max.poll.records` setting.<br><br>
     *
     * This setting effectively controls backpressure, i.e. the maximum number of batches to prefetch
-    * per topic-parititon before starting to slow down (not fetching more records) until processing
+    * per topic-partition before starting to slow down (not fetching more records) until processing
     * has caught-up.<br><br>
     *
     * Note that prefetching cannot be disabled and is generally preferred since it yields improved

diff --git a/modules/core/src/main/scala/fs2/kafka/consumer/KafkaAssignment.scala b/modules/core/src/main/scala/fs2/kafka/consumer/KafkaAssignment.scala
@@ -35,7 +35,7 @@ trait KafkaAssignment[F[_]] {
     * Manual topic assignment through this method does not use the consumer's group management
     * functionality. As such, there will be no rebalance operation triggered when group membership
     * or cluster and topic metadata change. Note that it is not possible to use both manual
-    * partition assignment with `assign` and group assigment with `subscribe`.<br><br>
+    * partition assignment with `assign` and group assignment with `subscribe`.<br><br>
     *
     * If auto-commit is enabled, an async commit (based on the old assignment) will be triggered
     * before the new assignment replaces the old one.<br><br>

diff --git a/modules/core/src/test/scala/fs2/kafka/BaseKafkaSpec.scala b/modules/core/src/test/scala/fs2/kafka/BaseKafkaSpec.scala
@@ -292,7 +292,7 @@ abstract class BaseKafkaSpec extends BaseAsyncSpec with ForAllTestContainer {
     producer.close()
 
     val _ = records.collectFirst { case Failure(ex) =>
-      throw new Exception("Kafka unavialable", ex)
+      throw new Exception("Kafka unavailable", ex)
     }
   }
 

diff --git a/modules/core/src/test/scala/fs2/kafka/KafkaConsumerSpec.scala b/modules/core/src/test/scala/fs2/kafka/KafkaConsumerSpec.scala
@@ -1065,7 +1065,7 @@ final class KafkaConsumerSpec extends BaseKafkaSpec {
 
         res.left.toOption match {
           case Some(e) => e shouldBe a[TimeoutException]
-          case _       => fail("No exception was rised!")
+          case _       => fail("No exception was raised!")
         }
       }
     }

diff --git a/modules/core/src/test/scala/fs2/kafka/security/KafkaCredentialStoreSpec.scala b/modules/core/src/test/scala/fs2/kafka/security/KafkaCredentialStoreSpec.scala
@@ -10,7 +10,7 @@ import fs2.kafka.BaseSpec
 
 final class KafkaCredentialStoreSpec extends BaseSpec {
   describe("KafkaCredentialStore") {
-    describe("fromPemStrigs") {
+    describe("fromPemStrings") {
       it("should create a KafkaCredentialStore with the expected properties") {
         val caCert =
           """-----BEGIN CERTIFICATE-----