Skip to content

Commit 41353c7

Browse files
committed
Fix typo
1 parent 207e67d commit 41353c7

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

pulsar/producer_partition.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -906,7 +906,7 @@ func (p *partitionProducer) writeData(buffer internal.Buffer, sequenceID uint64,
906906
buffer.Retain()
907907
conn := p._getConn()
908908
if p.getProducerState() == producerReady {
909-
// If the producer in reconnecting, we should not write to the connection.
909+
// If the producer is reconnecting, we should not write to the connection.
910910
// We just need to push the buffer to the pending queue, it will be sent during the reconnecting.
911911
conn.WriteData(ctx, buffer)
912912
} else {
@@ -1247,7 +1247,7 @@ func (p *partitionProducer) updateMetaData(sr *sendRequest) {
12471247
if !sr.sendAsBatch {
12481248
// update sequence id for metadata, make the size of msgMetadata more accurate
12491249
// batch sending will update sequence ID in the BatchBuilder
1250-
p.updateMetadataSeqID(sr.mm, sr.msg)
1250+
p.updateMetadataSeqID(sr.mm, sr.msg) // We shouldn't update the seq ID here!
12511251
}
12521252

12531253
sr.deliverAt = deliverAt

0 commit comments

Comments
 (0)