merge apache#1100: Construct the metadata after changing ReplicationClusters to __local__

gunli · gunli · commit dc03dd6e1d5f · 2023-10-08T15:27:18.000+08:00
diff --git a/pulsar/producer_partition.go b/pulsar/producer_partition.go
@@ -1039,13 +1039,13 @@ func (p *partitionProducer) updateMetaData(sr *sendRequest) {
 		deliverAt = time.Now().Add(sr.msg.DeliverAfter)
 	}
 
-	sr.mm = p.genMetadata(sr.msg, int(sr.uncompressedSize), deliverAt)
-
 	// set default ReplicationClusters when DisableReplication
 	if sr.msg.DisableReplication {
 		sr.msg.ReplicationClusters = []string{"__local__"}
 	}
 
+	sr.mm = p.genMetadata(sr.msg, int(sr.uncompressedSize), deliverAt)
+
 	sr.sendAsBatch = !p.options.DisableBatching &&
 		sr.msg.ReplicationClusters == nil &&
 		deliverAt.UnixNano() < 0

Original file line number	Diff line number	Diff line change
`@@ -1039,13 +1039,13 @@ func (p partitionProducer) updateMetaData(sr sendRequest) {`
`1039`	`1039`	`deliverAt = time.Now().Add(sr.msg.DeliverAfter)`
`1040`	`1040`	`}`
`1041`	`1041`
`1042`		`- sr.mm = p.genMetadata(sr.msg, int(sr.uncompressedSize), deliverAt)`
`1043`		`-`
`1044`	`1042`	`// set default ReplicationClusters when DisableReplication`
`1045`	`1043`	`if sr.msg.DisableReplication {`
`1046`	`1044`	`sr.msg.ReplicationClusters = []string{"__local__"}`
`1047`	`1045`	`}`
`1048`	`1046`
	`1047`	`+ sr.mm = p.genMetadata(sr.msg, int(sr.uncompressedSize), deliverAt)`
	`1048`	`+`
`1049`	`1049`	`sr.sendAsBatch = !p.options.DisableBatching &&`
`1050`	`1050`	`sr.msg.ReplicationClusters == nil &&`
`1051`	`1051`	`deliverAt.UnixNano() < 0`