diff --git a/lib/fluent/plugin/out_forward.rb b/lib/fluent/plugin/out_forward.rb index 5304ba2568..9fcea8923c 100644 --- a/lib/fluent/plugin/out_forward.rb +++ b/lib/fluent/plugin/out_forward.rb @@ -419,7 +419,7 @@ def statistics stats = super services = service_discovery_services healthy_nodes_count = 0 - registed_nodes_count = services.size + registered_nodes_count = services.size services.each do |s| if s.available? healthy_nodes_count += 1 @@ -427,8 +427,10 @@ def statistics end stats.merge( - 'healthy_nodes_count' => healthy_nodes_count, - 'registered_nodes_count' => registed_nodes_count, + 'output' => { + 'healthy_nodes_count' => healthy_nodes_count, + 'registered_nodes_count' => registered_nodes_count, + }, ) end