diff --git a/faust/tables/recovery.py b/faust/tables/recovery.py
index 74a729699..b4d49a930 100644
--- a/faust/tables/recovery.py
+++ b/faust/tables/recovery.py
@@ -691,9 +691,10 @@ async def _build_offsets(
         earliest = await consumer.earliest_offsets(*tps)
         # FIXME To be consistent with the offset -1 logic
         earliest = {tp: offset - 1 for tp, offset in earliest.items()}
+
         for tp in tps:
             last_value = destination[tp]
-            new_value = earliest[tp]
+            new_value = earliest.get(tp, None)
 
             if last_value is None:
                 destination[tp] = new_value