diff --git a/hstream-kafka/HStream/Kafka/Metrics/ConsumeStats.hs b/hstream-kafka/HStream/Kafka/Metrics/ConsumeStats.hs
index d7e8ddf87..263346ed9 100644
--- a/hstream-kafka/HStream/Kafka/Metrics/ConsumeStats.hs
+++ b/hstream-kafka/HStream/Kafka/Metrics/ConsumeStats.hs
@@ -28,6 +28,6 @@ totalConsumeRequest =
 
 consumerGroupCommittedOffsets :: P.Vector P.Label3 P.Gauge
 consumerGroupCommittedOffsets =
-  P.unsafeRegister . P.vector ("group", "topicName", "partition") . P.gauge $
+  P.unsafeRegister . P.vector ("consumer_group", "topicName", "partition") . P.gauge $
     P.Info "consumer_group_committed_offset" "Latest committed offset for a consumer group"
 {-# NOINLINE consumerGroupCommittedOffsets #-}
diff --git a/hstream-kafka/HStream/Kafka/Metrics/ProduceStats.hs b/hstream-kafka/HStream/Kafka/Metrics/ProduceStats.hs
index 9bb3b1fee..d2bab7216 100644
--- a/hstream-kafka/HStream/Kafka/Metrics/ProduceStats.hs
+++ b/hstream-kafka/HStream/Kafka/Metrics/ProduceStats.hs
@@ -29,5 +29,5 @@ totalProduceRequest =
 totalFailedProduceRequest :: P.Vector P.Label2 P.Counter
 totalFailedProduceRequest =
   P.unsafeRegister . P.vector ("topicName", "partition") . P.counter $
-    P.Info "total_produce_request" "Total failed produce request for a topic"
+    P.Info "total_failed_produce_request" "Total failed produce request for a topic"
 {-# NOINLINE totalFailedProduceRequest #-}
diff --git a/hstream-kafka/HStream/Kafka/Server/Handler/Consume.hs b/hstream-kafka/HStream/Kafka/Server/Handler/Consume.hs
index 81536eafc..bf55a7a08 100644
--- a/hstream-kafka/HStream/Kafka/Server/Handler/Consume.hs
+++ b/hstream-kafka/HStream/Kafka/Server/Handler/Consume.hs
@@ -184,7 +184,7 @@ handleFetch ServerContext{..} _ r = K.catchFetchResponseEx $ do
            if r.maxWaitMs > defTimeout
               then do
                 S.readerSetTimeout reader defTimeout
-                rs1 <- S.readerRead reader storageOpts.fetchMaxLen
+                rs1 <- P.observeDuration readLatencySnd $ S.readerRead reader storageOpts.fetchMaxLen
                 let size = sum (map (K.recordBytesSize . (.recordPayload)) rs1)
                 if size >= fromIntegral r.minBytes
                    then pure rs1