Skip to content

Commit 29faf60

Browse files
committed
Fix KeyError in KafkaConsumer.committed() (#2710)
1 parent d3f14f7 commit 29faf60

1 file changed

Lines changed: 2 additions & 1 deletion

File tree

kafka/coordinator/consumer.py

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -457,7 +457,8 @@ def fetch_committed_offsets(self, partitions, timeout_ms=None):
457457
self._client.poll(future=future, timeout_ms=timer.timeout_ms)
458458

459459
if future.is_done:
460-
del self._offset_fetch_futures[future_key]
460+
if future_key in self._offset_fetch_futures:
461+
del self._offset_fetch_futures[future_key]
461462

462463
if future.succeeded():
463464
return future.value

0 commit comments

Comments
 (0)