Merge pull request #444 from kianmeng/fix-typos

Fix typos
kafkaex · Oct 5, 2021 · 0f1dab8 · 0f1dab8
2 parents 0d22257 + 5723a47
commit 0f1dab8
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 3 deletions.
diff --git a/lib/kafka_ex/consumer_group/manager.ex b/lib/kafka_ex/consumer_group/manager.ex
@@ -274,7 +274,7 @@ defmodule KafkaEx.ConsumerGroup.Manager do
         timeout: session_timeout + session_timeout_padding
       )
 
-    # crash the worker if we recieve an error, but do it with a meaningful
+    # crash the worker if we receive an error, but do it with a meaningful
     # error message
     case join_response do
       %{error_code: :no_error} ->

diff --git a/lib/kafka_ex/server.ex b/lib/kafka_ex/server.ex
@@ -110,7 +110,7 @@ defmodule KafkaEx.Server do
             when reply: term, new_state: term, reason: term
   @callback kafka_server_offset(
               topic :: binary,
-              parition :: integer,
+              partition :: integer,
               time :: :calendar.datetime() | :latest | :earliest,
               state :: State.t()
             ) ::

diff --git a/new_api.md b/new_api.md
@@ -145,7 +145,7 @@ and some code to handle `api_version` in the opts:
 
 ```
 def get_broker_config_values(client, config_names, broker_id, opts \\ []) do
-  api_version = Keywork.get(opts, :api_version, 0)
+  api_version = Keyword.get(opts, :api_version, 0)
   # a setting in v1+
   include_synonyms = Keyword.get(opts, :include_synonyms, false)