rename updateUncompressPayload to updateUncompressedPayload

apache · Jul 27, 2023 · 3bd5c0e · 3bd5c0e
1 parent 118945f
commit 3bd5c0e
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/pulsar/producer_partition.go b/pulsar/producer_partition.go
@@ -1007,7 +1007,7 @@ func (p *partitionProducer) updateSchema(sr *sendRequest) error {
 	return nil
 }
 
-func (p *partitionProducer) updateUncompressPayload(sr *sendRequest) error {
+func (p *partitionProducer) updateUncompressedPayload(sr *sendRequest) error {
 	// read payload from message
 	sr.uncompressedPayload = sr.msg.Payload
 
@@ -1221,7 +1221,7 @@ func (p *partitionProducer) internalSendAsync(ctx context.Context, msg *Producer
 		return
 	}
 
-	err = p.updateUncompressPayload(sr)
+	err = p.updateUncompressedPayload(sr)
 	if err != nil {
 		p.log.Error(err)
 		sr.done(nil, err)