Updated kusto_spec.rb and ingestor_spec.rb

Testing spec files

e2e/e2e.rb

@@ -41,13 +41,15 @@ def initialize
       database => "#{@database}"
       table => "#{@table_with_mapping}"
       json_mapping => "#{@mapping_name}"
+      max_size => 2
     }
     kusto {
       path => "nomaptmp%{+YYYY-MM-dd-HH-mm}.txt"
       cli_auth => true
       ingest_url => "#{@ingest_url}"
       database => "#{@database}"
       table => "#{@table_without_mapping}"
+      max_size => 3
     }
   }
 }

lib/logstash/outputs/kusto/custom_size_based_buffer.rb

@@ -24,7 +24,7 @@ def <<(event)
         @mutex.synchronize do
           @buffer << event
           if @buffer.size >= @max_size
-            @logger.debug("Size-based flush triggered")
+            @logger.debug("Size-based flush triggered after #{@max_size} was reached")
             flush
           end
         end
@@ -47,7 +47,7 @@ def start_flusher_thread
             @mutex.synchronize do
               break if @shutdown
               if Time.now - @last_flush_time >= @max_interval
-                @logger.debug("Time-based flush triggered")
+                @logger.debug("Time-based flush triggered after #{@max_interval} seconds")
                 flush
               end
               @flusher_condition.wait(@mutex, @max_interval) # Wait for either the interval or shutdown signal