diff --git a/src/v/redpanda/application.cc b/src/v/redpanda/application.cc index 96c4fe8c775b..f7c5c2a549d8 100644 --- a/src/v/redpanda/application.cc +++ b/src/v/redpanda/application.cc @@ -68,6 +68,7 @@ #include "kafka/server/rm_group_frontend.h" #include "kafka/server/server.h" #include "kafka/server/snc_quota_manager.h" +#include "kafka/server/usage_manager.h" #include "model/fundamental.h" #include "model/metadata.h" #include "net/server.h" @@ -1340,6 +1341,9 @@ void application::wire_up_redpanda_services(model::node_id node_id) { controller.get()) .get(); + syschecks::systemd_message("Creating kafka usage manager frontend").get(); + construct_service(usage_manager, std::ref(storage)).get(); + syschecks::systemd_message("Creating tx coordinator frontend").get(); // usually it'a an anti-pattern to let the same object be accessed // from different cores without precautionary measures like foreign @@ -2022,6 +2026,7 @@ void application::start_runtime_services( quota_mgr.invoke_on_all(&kafka::quota_manager::start).get(); snc_quota_mgr.invoke_on_all(&kafka::snc_quota_manager::start).get(); + usage_manager.invoke_on_all(&kafka::usage_manager::start).get(); if (!config::node().admin().empty()) { _admin.invoke_on_all(&admin_server::start).get0(); diff --git a/src/v/redpanda/application.h b/src/v/redpanda/application.h index 7a7d41f468c0..ec1b1fb71154 100644 --- a/src/v/redpanda/application.h +++ b/src/v/redpanda/application.h @@ -123,6 +123,7 @@ class application { ss::sharded quota_mgr; ss::sharded snc_quota_mgr; ss::sharded rm_group_frontend; + ss::sharded usage_manager; ss::sharded raft_group_manager; ss::sharded recovery_throttle;