diff --git a/kafka/consumer/fetcher.py b/kafka/consumer/fetcher.py index 8e524790c..2027e8661 100644 --- a/kafka/consumer/fetcher.py +++ b/kafka/consumer/fetcher.py @@ -113,7 +113,7 @@ def __init__(self, client, subscriptions, **configs): be disabled in cases seeking extreme performance. Default: True isolation_level (str): Configure KIP-98 transactional consumer by setting to 'read_committed'. This will cause the consumer to - skip records from aborted tranactions. Default: 'read_uncommitted' + skip records from aborted transactions. Default: 'read_uncommitted' """ self.config = copy.copy(self.DEFAULT_CONFIG) for key in self.config: @@ -1289,7 +1289,7 @@ def to_send(self): @property def to_forget(self): - # Return as list of [(topic, (partiiton, ...)), ...] + # Return as list of [(topic, (partition, ...)), ...] # so it an be passed directly to encoder partition_data = collections.defaultdict(list) for tp in self._to_forget: