diff --git a/service/src/main/java/org/whispersystems/textsecuregcm/redis/ConnectionEventLogger.java b/service/src/main/java/org/whispersystems/textsecuregcm/redis/ConnectionEventLogger.java
index aa059b25b..193aafba7 100644
--- a/service/src/main/java/org/whispersystems/textsecuregcm/redis/ConnectionEventLogger.java
+++ b/service/src/main/java/org/whispersystems/textsecuregcm/redis/ConnectionEventLogger.java
@@ -5,23 +5,31 @@
 
 package org.whispersystems.textsecuregcm.redis;
 
+import static org.whispersystems.textsecuregcm.metrics.MetricsUtil.name;
+
 import io.lettuce.core.cluster.event.ClusterTopologyChangedEvent;
 import io.lettuce.core.event.connection.ConnectionEvent;
 import io.lettuce.core.resource.ClientResources;
+import io.micrometer.core.instrument.Metrics;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
 public class ConnectionEventLogger {
 
-    private static final Logger logger = LoggerFactory.getLogger(ConnectionEventLogger.class);
+  private static final String EVENT_COUNTER_NAME = name(ConnectionEventLogger.class, "events");
 
-    public static void logConnectionEvents(final ClientResources clientResources) {
-        clientResources.eventBus().get().subscribe(event -> {
-            if (event instanceof ConnectionEvent) {
-                logger.debug("Connection event: {}", event);
-            } else if (event instanceof ClusterTopologyChangedEvent) {
-                logger.info("Cluster topology changed: {}", event);
-            }
-        });
-    }
+  private static final Logger logger = LoggerFactory.getLogger(ConnectionEventLogger.class);
+
+  public static void logConnectionEvents(final ClientResources clientResources) {
+
+    clientResources.eventBus().get().subscribe(event -> {
+      if (event instanceof ConnectionEvent) {
+        logger.debug("Connection event: {}", event);
+      } else if (event instanceof ClusterTopologyChangedEvent) {
+        logger.info("Cluster topology changed: {}", event);
+      }
+
+      Metrics.counter(EVENT_COUNTER_NAME, "type", event.getClass().getSimpleName()).increment();
+    });
+  }
 }