update batch_size histo

PostHog · Nov 27, 2023 · bd29792 · bd29792
1 parent 106c34b
commit bd29792
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/capture/src/sink.rs b/capture/src/sink.rs
@@ -240,6 +240,7 @@ impl EventSink for KafkaSink {
         let limited = self.partition.is_limited(&event.key());
         let ack =
             Self::kafka_send(self.producer.clone(), self.topic.clone(), event, limited).await?;
+        histogram!("capture_event_batch_size", 1.0);
         Self::process_ack(ack).await
     }