diff --git a/src/v/pandaproxy/rest/proxy.cc b/src/v/pandaproxy/rest/proxy.cc index a84dfc1125dba..8df45df96bb5c 100644 --- a/src/v/pandaproxy/rest/proxy.cc +++ b/src/v/pandaproxy/rest/proxy.cc @@ -213,11 +213,12 @@ ss::future<> proxy::mitigate_error(std::exception_ptr eptr) { ss::future<> proxy::inform(model::node_id id) { vlog(plog.trace, "inform: {}", id); - const auto do_inform = [this](model::node_id n) -> ss::future<> { - auto& fe = _controller->get_ephemeral_credential_frontend().local(); - auto ec = co_await fe.inform(n, principal); - vlog(plog.info, "Informed: broker: {}, ec: {}", n, ec); - }; + const auto do_inform = ss::coroutine::lambda( + [this](model::node_id n) -> ss::future<> { + auto& fe = _controller->get_ephemeral_credential_frontend().local(); + auto ec = co_await fe.inform(n, principal); + vlog(plog.info, "Informed: broker: {}, ec: {}", n, ec); + }); // Inform a particular node if (id != kafka::client::unknown_node_id) { diff --git a/src/v/pandaproxy/schema_registry/service.cc b/src/v/pandaproxy/schema_registry/service.cc index ac2b3936dbe2f..cb4ddc4d6b12b 100644 --- a/src/v/pandaproxy/schema_registry/service.cc +++ b/src/v/pandaproxy/schema_registry/service.cc @@ -217,11 +217,12 @@ ss::future<> service::mitigate_error(std::exception_ptr eptr) { ss::future<> service::inform(model::node_id id) { vlog(plog.warn, "inform: {}", id); - const auto do_inform = [this](model::node_id n) -> ss::future<> { - auto& fe = _controller->get_ephemeral_credential_frontend().local(); - auto ec = co_await fe.inform(n, principal); - vlog(plog.warn, "Informed: broker: {}, ec: {}", n, ec); - }; + const auto do_inform = ss::coroutine::lambda( + [this](model::node_id n) -> ss::future<> { + auto& fe = _controller->get_ephemeral_credential_frontend().local(); + auto ec = co_await fe.inform(n, principal); + vlog(plog.warn, "Informed: broker: {}, ec: {}", n, ec); + }); // Inform a particular node if (id != kafka::client::unknown_node_id) {