out_opensearch_data_stream: Early return on empty body

Due to some reason the body could be empty which results in infinite jumps between failed buffer flushes. Opensearch returns a 400 with "request body is required".
fluent · Mar 6, 2024 · 146f71d · 146f71d
1 parent 0762b3f
commit 146f71d
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/lib/fluent/plugin/out_opensearch_data_stream.rb b/lib/fluent/plugin/out_opensearch_data_stream.rb
@@ -201,6 +201,8 @@ def write(chunk)
         end
       end
 
+      return if bulk_message.to_s.empty?
+
       params = {
         index: data_stream_name,
         body: bulk_message