Merge pull request #5607 from dotnwat/fix-5606

kafka: fix assertion failure in join_empty_group_static_member
redpanda-data · Jul 25, 2022 · 8bcf87f · 8bcf87f
2 parents 6d1d9ee + d940437
commit 8bcf87f
Showing 1 changed file with 8 additions and 7 deletions.
diff --git a/src/v/kafka/server/tests/consumer_groups_test.cc b/src/v/kafka/server/tests/consumer_groups_test.cc
@@ -96,12 +96,13 @@ FIXTURE_TEST(join_empty_group_static_member, consumer_offsets_fixture) {
           unknown_member_id, "group-test", {"p1", "p2"}, "random");
         // set group instance id
         req.data.group_instance_id = gr;
-        auto resp
-          = client.dispatch(std::move(req), kafka::api_version(5)).get0();
-        BOOST_REQUIRE(
-          resp.data.error_code == kafka::error_code::none
-          || resp.data.error_code == kafka::error_code::not_coordinator);
-        return resp.data.error_code == kafka::error_code::none
-               && resp.data.member_id != unknown_member_id;
+        return client.dispatch(std::move(req), kafka::api_version(5))
+          .then([&](auto resp) {
+              BOOST_REQUIRE(
+                resp.data.error_code == kafka::error_code::none
+                || resp.data.error_code == kafka::error_code::not_coordinator);
+              return resp.data.error_code == kafka::error_code::none
+                     && resp.data.member_id != unknown_member_id;
+          });
     }).get();
 }