Skip to content

Commit 5e125fa

Browse files
committed
revert is_reset_allowed change
1 parent baf6990 commit 5e125fa

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

kafka/consumer/subscription_state.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -474,7 +474,7 @@ def reset(self, strategy):
474474
self.next_allowed_retry_time = None
475475

476476
def is_reset_allowed(self):
477-
return (self.next_allowed_retry_time or -1) < time.time()
477+
return self.next_allowed_retry_time is None or self.next_allowed_retry_time < time.time()
478478

479479
@property
480480
def awaiting_reset(self):

0 commit comments

Comments
 (0)