diff --git a/kafka/codec.py b/kafka/codec.py
index 917400e74..c740a181c 100644
--- a/kafka/codec.py
+++ b/kafka/codec.py
@@ -187,7 +187,7 @@ def _detect_xerial_stream(payload):
         The version is the version of this format as written by xerial,
         in the wild this is currently 1 as such we only support v1.
 
-        Compat is there to claim the miniumum supported version that
+        Compat is there to claim the minimum supported version that
         can read a xerial block stream, presently in the wild this is
         1.
     """
diff --git a/kafka/coordinator/base.py b/kafka/coordinator/base.py
index 5e41309df..e71984108 100644
--- a/kafka/coordinator/base.py
+++ b/kafka/coordinator/base.py
@@ -952,7 +952,7 @@ def _run_once(self):
                 # disable here to prevent propagating an exception to this
                 # heartbeat thread
                 # must get client._lock, or maybe deadlock at heartbeat 
-                # failure callbak in consumer poll
+                # failure callback in consumer poll
                 self.coordinator._client.poll(timeout_ms=0)
 
         with self.coordinator._lock:
diff --git a/kafka/record/abc.py b/kafka/record/abc.py
index d5c172aaa..8509e23e5 100644
--- a/kafka/record/abc.py
+++ b/kafka/record/abc.py
@@ -85,7 +85,7 @@ def build(self):
 
 
 class ABCRecordBatch(object):
-    """ For v2 incapsulates a RecordBatch, for v0/v1 a single (maybe
+    """ For v2 encapsulates a RecordBatch, for v0/v1 a single (maybe
         compressed) message.
     """
     __metaclass__ = abc.ABCMeta
diff --git a/kafka/record/legacy_records.py b/kafka/record/legacy_records.py
index e2ee5490c..2f8523fcb 100644
--- a/kafka/record/legacy_records.py
+++ b/kafka/record/legacy_records.py
@@ -263,7 +263,7 @@ def __iter__(self):
 
                 # When magic value is greater than 0, the timestamp
                 # of a compressed message depends on the
-                # typestamp type of the wrapper message:
+                # timestamp type of the wrapper message:
                 if timestamp_type == self.LOG_APPEND_TIME:
                     timestamp = self._timestamp