redpanda: Allocate kafka::usage_manager at startup

graphcareful · Mar 16, 2023 · e22d9f0 · e22d9f0
1 parent 942d64c
commit e22d9f0
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 0 deletions.
diff --git 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
@@ -123,6 +123,7 @@ class application {
     ss::sharded<kafka::quota_manager> quota_mgr;
     ss::sharded<kafka::snc_quota_manager> snc_quota_mgr;
     ss::sharded<kafka::rm_group_frontend> rm_group_frontend;
+    ss::sharded<kafka::usage_manager> usage_manager;
 
     ss::sharded<raft::group_manager> raft_group_manager;
     ss::sharded<raft::recovery_throttle> recovery_throttle;