upgraded plugin to follow the fluentd v1 plugin API

lib/fluent/plugin/out_splunk.rb

@@ -1,13 +1,12 @@
 # frozen_string_literal: true
 
-require 'fluent/output'
 require 'fluent/plugin/output'
 require 'fluent/plugin/formatter'
 require 'prometheus/client'
 require 'benchmark'
 
 module Fluent::Plugin
-  class SplunkOutput < Fluent::BufferedOutput
+  class SplunkOutput < Fluent::Plugin::Output
     helpers :formatter
 
     autoload :VERSION, 'fluent/plugin/out_splunk/version'
@@ -100,9 +99,9 @@ def write(chunk)
         write_to_splunk(chunk)
       end
 
-      @metrics[:record_counter].increment(labels: metric_labels, by: chunk.size_of_events)
+      @metrics[:record_counter].increment(labels: metric_labels, by: chunk.size)
       @metrics[:bytes_counter].increment(labels: metric_labels, by: chunk.bytesize)
-      @metrics[:write_records_histogram].observe(chunk.size_of_events, labels: metric_labels)
+      @metrics[:write_records_histogram].observe(chunk.size, labels: metric_labels)
       @metrics[:write_bytes_histogram].observe(chunk.bytesize, labels: metric_labels, )
       @metrics[:write_latency_histogram].observe(t, labels: metric_labels, )
     end

lib/fluent/plugin/out_splunk_hec.rb

@@ -140,6 +140,10 @@ def configure(conf)
       pick_custom_format_method
     end
 
+    def write(chunk)
+      super
+    end
+
     def start
       super
       @conn = Net::HTTP::Persistent.new.tap do |c|

lib/fluent/plugin/out_splunk_ingest_api.rb

@@ -41,6 +41,10 @@ def configure(conf)
       super
     end
 
+    def write(chunk)
+      super
+    end
+
     def construct_api
       uri = "https://#{@ingest_api_host}/#{@ingest_api_tenant}#{@ingest_api_events_endpoint}"
       URI(uri)
@@ -101,7 +105,7 @@ def new_connection
     end
 
     def write_to_splunk(chunk)
-      log.trace "#{self.class}: In write() with #{chunk.size_of_events} records and #{chunk.bytesize} bytes "
+      log.trace "#{self.class}: In write() with #{chunk.size} records and #{chunk.bytesize} bytes "
       # ingest API is an array of json objects
       body = "[#{chunk.read.chomp(',')}]"
       @conn ||= new_connection