diff --git a/arroyo/processing/strategies/commit.py b/arroyo/processing/strategies/commit.py
index e447d2ad..e79cdbd5 100644
--- a/arroyo/processing/strategies/commit.py
+++ b/arroyo/processing/strategies/commit.py
@@ -27,7 +27,7 @@ def submit(self, message: Message[Any]) -> None:
         now = time.time()
         if self.__last_record_time is None or now - self.__last_record_time > 1:
             if message.timestamp is not None:
-                self.__metrics.increment(
+                self.__metrics.timing(
                     "arroyo.consumer.latency", now - message.timestamp.timestamp()
                 )
                 self.__last_record_time = now