KafkaError NOT_COORDINATOR_FOR_GROUP renamed to NOT_COORDINATOR

Author: edenhill

confluent_kafka/kafkatest/verifiable_consumer.py

@@ -172,7 +172,7 @@ def do_commit(self, immediate=False, asynchronous=None):
                     self.dbg('No offsets to commit')
                     break
                 elif e.args[0].code() in (KafkaError.REQUEST_TIMED_OUT,
-                                          KafkaError.NOT_COORDINATOR_FOR_GROUP,
+                                          KafkaError.NOT_COORDINATOR,
                                           KafkaError._WAIT_COORD):
                     self.dbg('Commit failed: %s (%d retries)' % (str(e), retries))
                     if retries <= 0: