Fixed buffer resize when writing request on connection (#374)

apache · Oct 1, 2020 · 7dd67c9 · 7dd67c9
1 parent 3c523ba
commit 7dd67c9
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/pulsar/internal/connection.go b/pulsar/internal/connection.go
@@ -470,6 +470,7 @@ func (c *connection) writeCommand(cmd *pb.BaseCommand) {
 	c.writeBuffer.WriteUint32(frameSize)
 
 	c.writeBuffer.WriteUint32(cmdSize)
+	c.writeBuffer.ResizeIfNeeded(cmdSize)
 	_, err := cmd.MarshalToSizedBuffer(c.writeBuffer.WritableSlice()[:cmdSize])
 	if err != nil {
 		c.log.WithError(err).Fatal("Protobuf serialization error")