From bd29792f06a519decd40938724102cbccd192c3a Mon Sep 17 00:00:00 2001
From: Xavier Vello <xavier@posthog.com>
Date: Mon, 27 Nov 2023 13:33:15 +0100
Subject: [PATCH] update batch_size histo

---
 capture/src/sink.rs | 1 +
 1 file changed, 1 insertion(+)

diff --git a/capture/src/sink.rs b/capture/src/sink.rs
index 724f47c..c1d291a 100644
--- 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
     }