diff --git a/kafka/coordinator/consumer.py b/kafka/coordinator/consumer.py
index 0bce86aaf..58869d61a 100644
--- a/kafka/coordinator/consumer.py
+++ b/kafka/coordinator/consumer.py
@@ -453,7 +453,8 @@ def fetch_committed_offsets(self, partitions, timeout_ms=None):
             self._client.poll(future=future, timeout_ms=timer.timeout_ms)
 
             if future.is_done:
-                del self._offset_fetch_futures[future_key]
+                if future_key in self._offset_fetch_futures:
+                    del self._offset_fetch_futures[future_key]
 
                 if future.succeeded():
                     return future.value