buffer = self.protocol.write().FetchRequest({
                correlationId: correlationId,
                clientId: self.options.clientId,
                maxWaitTime: self.options.maxWaitTime,
                minBytes: self.options.minBytes,