diff --git a/aiokafka/consumer/fetcher.py b/aiokafka/consumer/fetcher.py
index 131ad135..df59c925 100644
--- a/aiokafka/consumer/fetcher.py
+++ b/aiokafka/consumer/fetcher.py
@@ -512,7 +512,8 @@ def on_done(fut, self=self):
                         # cancellation
                         if not task.done():
                             task.cancel()
-                        await task
+                        with contextlib.suppress(asyncio.CancelledError):
+                            await task
                     self._pending_tasks.clear()
                     self._records.clear()