Skip to content

Commit

Permalink
redpanda/application: using port based shard connections assignment
Browse files Browse the repository at this point in the history
Using port based shard connection assignment in RPC server. This makes
incoming connection shard assignment deterministic.

Signed-off-by: Michal Maslanka <michal@vectorized.io>
  • Loading branch information
mmaslankaprv committed Nov 3, 2020
1 parent 4a44366 commit fc03832
Showing 1 changed file with 6 additions and 0 deletions.
6 changes: 6 additions & 0 deletions src/v/redpanda/application.cc
Original file line number Diff line number Diff line change
Expand Up @@ -367,6 +367,12 @@ void application::wire_up_services() {
construct_service(_quota_mgr).get();
// rpc
rpc::server_configuration rpc_cfg("internal_rpc");
/**
* Use port based load_balancing_algorithm to make connection shard
* assignment deterministic.
**/
rpc_cfg.load_balancing_algo
= ss::server_socket::load_balancing_algorithm::port;
rpc_cfg.max_service_memory_per_core = memory_groups::rpc_total_memory();
auto rpc_server_addr
= config::shard_local_cfg().rpc_server().resolve().get0();
Expand Down

0 comments on commit fc03832

Please sign in to comment.