var buffer = self.protocol.write().ProduceRequest({
                    correlationId: correlationId,
                    clientId: self.options.clientId,
                    requiredAcks: self.options.requiredAcks,
                    timeout: self.options.timeout,