tests/clients: rpk describe group error handling

vbotbuildovich · Aug 8, 2022 · bcb2102 · bcb2102
1 parent 0c687f9
commit bcb2102
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/tests/rptest/clients/rpk.py b/tests/rptest/clients/rpk.py
@@ -415,6 +415,10 @@ def try_describe_group(group):
                 if "COORDINATOR_NOT_AVAILABLE" in e.msg:
                     # Transient, return None to retry
                     return None
+                elif "Kafka replied that group" in e.msg:
+                    # Transient, return None to retry
+                    # e.g. Kafka replied that group repeat01 has broker coordinator 8, but did not reply with that broker in the broker list
+                    return None
                 else:
                     raise