sinkv2(ticdc): observe row size in MQ sink (#8287)

close #8286
pingcap · Feb 17, 2023 · 03416c5 · 03416c5
1 parent 7e6800f
commit 03416c5
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/cdc/sinkv2/eventsink/mq/worker.go b/cdc/sinkv2/eventsink/mq/worker.go
@@ -215,6 +215,7 @@ func (w *worker) batch(
 			return index, nil
 		}
 		if msg.rowEvent != nil {
+			w.statistics.ObserveRows(msg.rowEvent.Event)
 			events[index] = msg
 			index++
 		}
@@ -233,6 +234,7 @@ func (w *worker) batch(
 			}
 
 			if msg.rowEvent != nil {
+				w.statistics.ObserveRows(msg.rowEvent.Event)
 				events[index] = msg
 				index++
 			}