fix(consumer): Update arbitrarily renamed KafkaError in retry policy (

#1429)
getsentry · Oct 15, 2020 · dc4eb70 · dc4eb70
1 parent 4d36cc0
commit dc4eb70
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/snuba/consumers/consumer_builder.py b/snuba/consumers/consumer_builder.py
@@ -117,7 +117,7 @@ def __init__(
                 and e.args[0].code()
                 in (
                     KafkaError.REQUEST_TIMED_OUT,
-                    KafkaError.NOT_COORDINATOR_FOR_GROUP,
+                    KafkaError.NOT_COORDINATOR,
                     KafkaError._WAIT_COORD,
                 ),
             )