diff --git a/splitter/metrics.go b/splitter/metrics.go
index a2173a63..76161ce4 100644
--- a/splitter/metrics.go
+++ b/splitter/metrics.go
@@ -9,3 +9,8 @@ var eventsSentCounter = promauto.NewCounterVec(prometheus.CounterOpts{
 	Name: "spl_events_sent_counter",
 	Help: "The total number of events sent to consumers",
 }, []string{"remote_addr", "user_agent"})
+
+var activeClientGauge = promauto.NewGauge(prometheus.GaugeOpts{
+	Name: "spl_active_clients",
+	Help: "Current number of active clients",
+})
diff --git a/splitter/splitter.go b/splitter/splitter.go
index c13d5e48..8f335063 100644
--- a/splitter/splitter.go
+++ b/splitter/splitter.go
@@ -269,6 +269,8 @@ func (s *Splitter) EventsHandler(c echo.Context) error {
 		"cursor", since,
 		"consumer_id", consumerID,
 	)
+	activeClientGauge.Inc()
+	defer activeClientGauge.Dec()
 
 	for {
 		select {