diff --git a/src/v/kafka/server/snc_quota_manager.cc b/src/v/kafka/server/snc_quota_manager.cc index 56427c685769..6a61c1a55638 100644 --- 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 index 2e0f236f8244..ac2f9bb08e65 100644 --- 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 _kafka_quota_balancer_min_shard_throughput_ratio; config::binding _kafka_quota_balancer_min_shard_throughput_bps; + config::binding> + _kafka_throughput_control; // operational, only used in the balancer shard ss::timer _balancer_timer;