lib/logstash/inputs/processor.rb in logstash-input-azure_event_hubs-1.1.3 vs lib/logstash/inputs/processor.rb in logstash-input-azure_event_hubs-1.1.4

@@ -24,10 +24,10 @@
         def onClose(context, reason)
           @logger.info("Event Hub: #{context.getEventHubPath.to_s}, Partition: #{context.getPartitionId.to_s} is closing. (reason=#{reason.to_s})")
         end
 
         def onEvents(context, batch)
-          @logger.debug("Event Hub: #{context.getEventHubPath.to_s}, Partition: #{context.getPartitionId.to_s} is processing a batch.") if @logger.debug?
+          @logger.debug("Event Hub: #{context.getEventHubPath.to_s}, Partition: #{context.getPartitionId.to_s} is processing a batch of size #{batch.size}.") if @logger.debug?
           last_payload = nil
           batch_size = 0
           batch.each do |payload|
             last_checkpoint = Time.now.to_i
             bytes = payload.getBytes