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 75318bd72..5ba9fa431 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("%d %s %v\n", counter, string(key), record) + fmt.Printf("%d %s %v\n", counter, string(key), record.Field2) }, func() { log.Printf("done received %d messages", counter) })