diff --git a/lib/fluent/plugin/out_opensearch_data_stream.rb b/lib/fluent/plugin/out_opensearch_data_stream.rb index 6418031..805baf4 100644 --- a/lib/fluent/plugin/out_opensearch_data_stream.rb +++ b/lib/fluent/plugin/out_opensearch_data_stream.rb @@ -160,7 +160,11 @@ def write(chunk) data_stream_template_name = @data_stream_template_name host = nil if @use_placeholder - host = extract_placeholders(@host, chunk) + host = if @hosts + extract_placeholders(@hosts, chunk) + else + extract_placeholders(@host, chunk) + end data_stream_name = extract_placeholders(@data_stream_name, chunk) data_stream_template_name = extract_placeholders(@data_stream_template_name, chunk) unless @data_stream_names.include?(data_stream_name)