diff --git a/lib/fluent/plugin/in_forward.rb b/lib/fluent/plugin/in_forward.rb index 7b56236fa9..54e7da80fb 100644 --- a/lib/fluent/plugin/in_forward.rb +++ b/lib/fluent/plugin/in_forward.rb @@ -151,7 +151,7 @@ def multi_workers_ready? def start super - shared_socket = false # TODO: turn it true if configured as multi workers + shared_socket = system_config.workers > 1 log.info "listening a tcp port", port: @port, bind: @bind server_create_connection(