diff --git a/lib/fluent/plugin/out_opensearch_data_stream.rb b/lib/fluent/plugin/out_opensearch_data_stream.rb
index 2b8e7f2..9140d8f 100644
--- 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