log command before sending to broker

Fanatics · Oct 25, 2023 · 17ebfeb · 17ebfeb
1 parent fedeeda
commit 17ebfeb
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/pulsar/internal/connection.go b/pulsar/internal/connection.go
@@ -502,6 +502,9 @@ func (c *connection) writeCommand(cmd *pb.BaseCommand) {
 		panic("Protobuf serialization error")
 	}
 
+	// log the command before sending to broker, it will be helpful for debugging in case of issues
+	c.log.Debugf("Writing command: %v", cmd)
+
 	c.writeBuffer.WrittenBytes(cmdSize)
 	c.internalWriteData(c.writeBuffer)
 }