k/quotas: binding for "kafka_throughput_control"

redpanda-data · Jun 2, 2023 · 2ded90f · 2ded90f
1 parent 7af5c60
commit 2ded90f
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 0 deletions.
diff --git a/src/v/kafka/server/snc_quota_manager.cc b/src/v/kafka/server/snc_quota_manager.cc
@@ -148,6 +148,7 @@ snc_quota_manager::snc_quota_manager()
   , _kafka_quota_balancer_min_shard_throughput_bps(
       config::shard_local_cfg()
         .kafka_quota_balancer_min_shard_throughput_bps.bind())
+  , _kafka_throughput_control(config::shard_local_cfg().kafka_throughput_control.bind())
   , _node_quota_default{calc_node_quota_default()}
   , _shard_quota{
       .in {node_to_shard_quota(_node_quota_default.in),

diff --git a/src/v/kafka/server/snc_quota_manager.h b/src/v/kafka/server/snc_quota_manager.h
@@ -11,6 +11,7 @@
 
 #pragma once
 #include "config/property.h"
+#include "config/throughput_control_group.h"
 #include "seastarx.h"
 #include "utils/bottomless_token_bucket.h"
 #include "utils/mutex.h"
@@ -171,6 +172,8 @@ class snc_quota_manager
       _kafka_quota_balancer_node_period;
     config::binding<double> _kafka_quota_balancer_min_shard_throughput_ratio;
     config::binding<quota_t> _kafka_quota_balancer_min_shard_throughput_bps;
+    config::binding<std::vector<config::throughput_control_group>>
+      _kafka_throughput_control;
 
     // operational, only used in the balancer shard
     ss::timer<ss::lowres_clock> _balancer_timer;