Skip to content

Commit ee37195

Browse files
Merge pull request #29478 from michael-redpanda/gbac/core-15351-flaky-gbac
CORE-15351: Deflake upgrade gbac test
2 parents f5752c0 + aeedcfd commit ee37195

File tree

2 files changed

+14
-5
lines changed

2 files changed

+14
-5
lines changed

src/v/kafka/server/server.cc

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -2061,7 +2061,11 @@ ss::future<response_ptr> create_acls_handler::handle(
20612061
error_code::invalid_config, "GBAC feature not yet active");
20622062
} else {
20632063
response.data.results.emplace_back(
2064-
map_topic_error_code(results[i]));
2064+
map_topic_error_code(results[i]),
2065+
results[i] == cluster::errc::success
2066+
? std::nullopt
2067+
: std::make_optional<ss::sstring>(
2068+
fmt::format("{}", results[i])));
20652069
}
20662070
},
20672071
[&response](creatable_acl_result r) {

tests/rptest/tests/acls_test.py

Lines changed: 9 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -724,11 +724,16 @@ def test_upgrade_gbac(self):
724724
acl_input.operation = ["all"]
725725
acl_input.cluster = True
726726

727-
result = self.get_super_client().acl_create(acl=acl_input)
728-
self.logger.debug(f"Result: {result}")
727+
def wait_for_gbac_feature_response():
728+
result = self.get_super_client().acl_create(acl=acl_input)
729+
self.logger.debug(f"result: {result}")
730+
return "INVALID_CONFIG: GBAC feature not yet active" in result
729731

730-
assert "INVALID_CONFIG: GBAC feature not yet active" in result, (
731-
f"Unexpected result: {result}"
732+
wait_until(
733+
wait_for_gbac_feature_response,
734+
timeout_sec=30,
735+
backoff_sec=1,
736+
err_msg="Timed out waiting for GBAC feature response",
732737
)
733738

734739
# Upgrade remaining nodes

0 commit comments

Comments
 (0)