Use uint ptr instead int64

apache · Feb 6, 2023 · 6a9afbc · 6a9afbc
1 parent aec822e
commit 6a9afbc
Showing 1 changed file with 5 additions and 5 deletions.
diff --git a/pulsar/producer_partition.go b/pulsar/producer_partition.go
@@ -95,7 +95,7 @@ type partitionProducer struct {
 	metrics          *internal.LeveledMetrics
 	epoch            uint64
 	schemaCache      *schemaCache
-	topicEpoch       int64
+	topicEpoch       *uint64
 }
 
 type schemaCache struct {
@@ -162,7 +162,6 @@ func newPartitionProducer(client *client, topic string, options *ProducerOptions
 		metrics:          metrics,
 		epoch:            0,
 		schemaCache:      newSchemaCache(),
-		topicEpoch:       -1,
 	}
 	if p.options.DisableBatching {
 		p.batchFlushTicker.Stop()
@@ -242,8 +241,8 @@ func (p *partitionProducer) grabCnx() error {
 		ProducerAccessMode:       toProtoProducerAccessMode(p.options.ProducerAccessMode).Enum(),
 	}
 
-	if p.topicEpoch > -1 {
-		cmdProducer.TopicEpoch = proto.Uint64(uint64(p.topicEpoch))
+	if p.topicEpoch != nil {
+		cmdProducer.TopicEpoch = proto.Uint64(*p.topicEpoch)
 	}
 
 	if p.producerName != "" {
@@ -260,7 +259,8 @@ func (p *partitionProducer) grabCnx() error {
 	}
 
 	p.producerName = res.Response.ProducerSuccess.GetProducerName()
-	p.topicEpoch = int64(res.Response.ProducerSuccess.GetTopicEpoch())
+	nextTopicEpoch := res.Response.ProducerSuccess.GetTopicEpoch()
+	p.topicEpoch = &nextTopicEpoch
 
 	if p.options.Encryption != nil {
 		p.encryptor = internalcrypto.NewProducerEncryptor(p.options.Encryption.Keys,