From fc03832ca6aa965cd09f9ccf2689b6921836dcfa Mon Sep 17 00:00:00 2001 From: Michal Maslanka Date: Tue, 3 Nov 2020 09:50:44 +0100 Subject: [PATCH] redpanda/application: using port based shard connections assignment Using port based shard connection assignment in RPC server. This makes incoming connection shard assignment deterministic. Signed-off-by: Michal Maslanka --- src/v/redpanda/application.cc | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/src/v/redpanda/application.cc b/src/v/redpanda/application.cc index b5739f985a829..2a3d0355905b0 100644 --- a/src/v/redpanda/application.cc +++ b/src/v/redpanda/application.cc @@ -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();