enabled tag interpolation for source value (#203)

splunk · Dec 14, 2021 · 76c60c2 · 76c60c2
1 parent 8f657c4
commit 76c60c2
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/lib/fluent/plugin/out_splunk.rb b/lib/fluent/plugin/out_splunk.rb
@@ -193,8 +193,8 @@ def prepare_key_fields
           v = instance_variable_get "@#{f}"
           next unless v
 
-          if v == TAG_PLACEHOLDER
-            instance_variable_set "@#{f}", ->(tag, _) { tag }
+          if v.include? TAG_PLACEHOLDER
+            instance_variable_set "@#{f}", ->(tag, _) { v.gsub(TAG_PLACEHOLDER, tag) }
           else
             instance_variable_set "@#{f}", ->(_, _) { v }
           end