diff --git a/weed/mq/client/cmd/agent_sub_record/agent_sub_record.go b/weed/mq/client/cmd/agent_sub_record/agent_sub_record.go
index 80313e4d1..c17938515 100644
--- a/weed/mq/client/cmd/agent_sub_record/agent_sub_record.go
+++ b/weed/mq/client/cmd/agent_sub_record/agent_sub_record.go
@@ -46,7 +46,7 @@ func main() {
 	session.SubscribeMessageRecord(func(key []byte, recordValue *schema_pb.RecordValue) {
 		counter++
 		record := example.FromRecordValue(recordValue)
-		fmt.Printf("%s %v\n", string(key), record)
+		fmt.Printf("%d %s %v\n", counter, string(key), record)
 	}, func() {
 		log.Printf("done received %d messages", counter)
 	})