[GitHub] [pulsar] lichuan6 edited a comment on issue #9186: record.getPublishTime return empty

[GitBox <gi...@apache.org>]

lichuan6 edited a comment on issue #9186:
URL: https://github.com/apache/pulsar/issues/9186#issuecomment-759337140


   I wrote an application and tried to consume message using go client, and I can retreive the publishtime from `msg.PublishTime()`.
   
   ```go
   package main
   
   import (
   	"context"
   	"fmt"
   	"log"
   	"time"
   
   	"github.com/apache/pulsar-client-go/pulsar"
   )
   
   var (
   	token = "ey<...>"
   )
   
   func main() {
   	client, err := pulsar.NewClient(pulsar.ClientOptions{
   		URL:               "pulsar://pulsar-broker.pulsar:6650",
   		OperationTimeout:  30 * time.Second,
   		ConnectionTimeout: 30 * time.Second,
   		Authentication:    pulsar.NewAuthenticationToken(token),
   	})
   	if err != nil {
   		log.Fatalf("Could not instantiate Pulsar client: %v", err)
   	}
   
   	defer client.Close()
   
   	consumer, err := client.Subscribe(pulsar.ConsumerOptions{
   		Topic:            "public/default/pulsar",
   		SubscriptionName: "my-pulsar-sub-test",
   		Type:             pulsar.Shared,
   	})
   	if err != nil {
   		log.Fatal(err)
   	}
   	defer consumer.Close()
   
   	for {
   		for i := 0; i < 10; i++ {
   			msg, err := consumer.Receive(context.Background())
   			if err != nil {
   				log.Fatal(err)
   			}
   
   			fmt.Printf("Received msgId: %#v, PublishTime : %v, -- content: '%s'\n",
   				msg.ID(),
   				msg.PublishTime(),
   				string(msg.Payload()))
   
   			consumer.Ack(msg)
   		}
   		time.Sleep(5 * time.Second)
   		log.Printf("Sleeping 5s ...")
   		fmt.Printf("Sleeping 5s ...")
   	}
   }
   
   ```
   
   output from pod:
   ```
   Received msgId: pulsar.trackingMessageID{messageID:pulsar.messageID{ledgerID:31878, entryID:4294, batchIdx:11, partitionIdx:0}, tracker:(*pulsar.ackTracker)(0xc0000976c0), consumer:(*pulsar.partitionConsumer)(0xc000292000), receivedTime:time.Time{wall:0xbff7ce429a0c36bb, ext:10088415541, loc:(*time.Location)(0xf47940)}}, PublishTime : 2021-01-13 17:46:50.43 +0800 CST, -- content: '{"kubernetes.annotations.kubernetes.io/psp":"eks.privileged","kubernetes.annotations.prometheus.io/port":"80","kubernetes.annotations.prometheus.io/scrape":"true","kubernetes.container_hash":"123123123123.dkr.ecr.cn-northwest-1.amazonaws.com.cn/apachepulsar/pulsar-all@sha256:6a181bfd32cd36271034a3e9c325d5ac7625b8d5b4c5fc0154434f176d8389c2","kubernetes.container_image":"123123123123.dkr.ecr.cn-northwest-1.amazonaws.com.cn/apachepulsar/pulsar-all:2.6.1","kubernetes.container_name":"pulsar-proxy","kubernetes.docker_id":"f235aa5d86b7aa8600ec615306e379cc8f5ad66447cd58e1aa807a1766dfc59e","kubernetes.host":"ip-
 172-24-162-12.cn-northwest-1.compute.internal","kubernetes.labels.app":"pulsar","kubernetes.labels.cluster":"2.6.1-pulsar","kubernetes.labels.component":"proxy","kubernetes.labels.controller-revision-hash":"pulsar-proxy-86dcb67f7b","kubernetes.labels.redeploy":"1609826649","kubernetes.labels.release":"2.6.1","kubernetes.labels.statefulset.kubernetes.io/pod-name":"pulsar-proxy-3","kubernetes.namespace_name":"pulsar","kubernetes.pod_id":"4bad6623-d9ae-408c-81c0-5e065868d455","kubernetes.pod_name":"pulsar-proxy-3","log":"09:46:49.647 [pulsar-proxy-io-2-1] INFO  org.apache.pulsar.proxy.server.ProxyConnection - [/172.24.136.239:45046] New connection opened\n","stream":"stdout"}'
   ```


----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
users@infra.apache.org