diff --git a/lib/kafka_ex/consumer_group/manager.ex b/lib/kafka_ex/consumer_group/manager.ex
index aec56935..ec22e041 100644
--- 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
index 7f1f274b..e2958e0d 100644
--- 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
index ff79038e..44725e71 100644
--- 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)