5 SrSSKJr SSKJr SSKJr SSKJr Sr "SS\R5r "S S \R5r "S S \R5r "S S\R5r"SS\R5r"SS\R5r"SS\R5r"SS\R5r"SS\R5r"SS\R5r"SS\R5r"SS\R5r"SS \R5r"S!S"\R5r"S#S$\R5r"S%S&\R5r"S'S(\R5r"S)S*\R5r"S+S,\R5r"S-S.\R5r"S/S0\R5r"S1S2\R5r "S3S4\R5r!"S5S6\R5r""S7S8\R5r#"S9S:\R5r$"S;S<\R5r%"S=S>\R5r&"S?S@\R5r'"SASB\R5r("SCSD\R5r)"SESF\R5r*"SGSH\R5r+"SISJ\R5r,"SKSL\R5r-"SMSN\R5r."SOSP\R5r/"SQSR\R5r0"SSST\R5r1"SUSV\R5r2"SWSX\R5r3"SYSZ\R5r4"S[S\\R5r5"S]S^\R5r6"S_S`\R5r7"SaSb\R5r8"ScSd\R5r9"SeSf\R5r:"SgSh\R5r;"SiSj\R5r<"SkSl\R5r="SmSn\R5r>"SoSp\R5r?"SqSr\R5r@"SsSt\R5rA"SuSv\R5rB"SwSx\R5rC"SySz\R5rD"S{S|\R5rE"S}S~\R5rF"SS\R5rG"SS\R5rH"SS\R5rI"SS\R5rJ"SS\R5rK"SS\R5rL"SS\R5rM"SS\R5rN"SS\R5rO"SS\R5rP"SS\R5rQ"SS\R5rR"SS\R5rS"SS\R5rT"SS\R5rU"SS\R5rV"SS\R5rW"SS\R5rX"SS\R5rY"SS\R5rZ"SS\R5r["SS\R5r\"SS\R5r]"SS\R5r^"SS\R5r_"SS\R5r`"SS\R5ra"SS\R5rb"SS\R5rc"SS\R5rd"SS\R5re"SS\R5rf"SS\R5rg"SS\R5rh"SS\R5ri"SS\R5rj"SS\R5rk"SS\R5rl"SS\R5rm"SS\R5rn"SS\R5ro"SS\R5rp"SS\R5rq"SS\R5rr"SS\R5rs"SS\R5rt"SS\R5ru"SS\R5rv"SS\R5rw"SS\R5rx"SS\R5ry"SS\R5rz"SS\R5r{"SS\R5r|"SS\R5r}"SS\R5r~"SS\R5r"SS\R5r"SS\R5r"SS\R5r"SS\R5r"SS\R5r"SS\R5r"SS\R5r"SGS\R5r"GSGS\R5r"GSGS\R5r"GSGS\R5r"GSGS\R5r"GS GS \R5r"GS GS \R5r"GS GS\R5r"GSGS\R5r"GSGS\R5r"GSGS\R5r"GSGS\R5r"GSGS\R5r"GSGS\R5r"GSGS\R5r"GSGS\R5r"GSGS \R5r"GS!GS"\R5r"GS#GS$\R5r"GS%GS&\R5r"GS'GS(\R5r"GS)GS*\R5r"GS+GS,\R5r"GS-GS.\R5r"GS/GS0\R5r"GS1GS2\R5r"GS3GS4\R5r"GS5GS6\R5r"GS7GS8\R5r"GS9GS:\R5r"GS;GS<\R5r"GS=GS>\R5r\GRN"\GS?GS@5 \GRP"\GRRGSAGSB5 \GRP"\GRRGSCGSD5 GgE(FzdGenerated message classes for managedkafka version v1. Manage Apache Kafka clusters and resources. )absolute_import)messages)encoding) extra_types managedkafkac<\rSrSrSr\R "SSSS9rSrg) AccessConfigaThe configuration of access to the Kafka cluster. Fields: networkConfigs: Required. Virtual Private Cloud (VPC) networks that must be granted direct access to the Kafka cluster. Minimum of 1 network is required. Maximum 10 networks can be specified. NetworkConfigTrepeatedN __name__ __module__ __qualname____firstlineno____doc__ _messages MessageFieldnetworkConfigs__static_attributes__rUlib/googlecloudsdk/generated_clients/apis/managedkafka/v1/managedkafka_v1_messages.pyr r s))/1tL.rr c\rSrSrSr\R "SSSS9r\R"S5r \R"S5r \R"S 5r \R"S 5r \R"S 5r S rg )AclaQRepresents the set of ACLs for a given Kafka Resource Pattern, which consists of resource_type, resource_name and pattern_type. Fields: aclEntries: Required. The ACL entries that apply to the resource pattern. The maximum number of allowed entries 100. etag: Optional. `etag` is used for concurrency control. An `etag` is returned in the response to `GetAcl` and `CreateAcl`. Callers are required to put that etag in the request to `UpdateAcl` to ensure that their change will be applied to the same version of the acl that exists in the Kafka Cluster. A terminal 'T' character in the etag indicates that the AclEntries were truncated; more entries for the Acl exist on the Kafka Cluster, but can't be returned in the Acl due to repeated field limits. name: Identifier. The name for the acl. Represents a single Resource Pattern. Structured like: projects/{project}/locations/{location}/clusters/{cluster}/acls/{acl_id} The structure of `acl_id` defines the Resource Pattern (resource_type, resource_name, pattern_type) of the acl. `acl_id` is structured like one of the following: For acls on the cluster: `cluster` For acls on a single resource within the cluster: `topic/{resource_name}` `consumerGroup/{resource_name}` `transactionalId/{resource_name}` For acls on all resources that match a prefix: `topicPrefixed/{resource_name}` `consumerGroupPrefixed/{resource_name}` `transactionalIdPrefixed/{resource_name}` For acls on all resources of a given type (i.e. the wildcard literal "*"): `allTopics` (represents `topic/*`) `allConsumerGroups` (represents `consumerGroup/*`) `allTransactionalIds` (represents `transactionalId/*`) patternType: Output only. The ACL pattern type derived from the name. One of: LITERAL, PREFIXED. resourceName: Output only. The ACL resource name derived from the name. For cluster resource_type, this is always "kafka-cluster". Can be the wildcard literal "*". resourceType: Output only. The ACL resource type derived from the name. One of: CLUSTER, TOPIC, GROUP, TRANSACTIONAL_ID. AclEntryr Tr rN)rrrrrrr aclEntries StringFieldetagname patternType resourceName resourceTyperrrrrrsn#J%%j!dC*   q !$   q !$%%a(+&&q),&&q),rrc\rSrSrSr\R "S5r\R "S5r\R "S5r \R "S5r Sr g) rKaRepresents the access granted for a given Resource Pattern in an ACL. Fields: host: Required. The host. Must be set to "*" for Managed Service for Apache Kafka. operation: Required. The operation type. Allowed values are (case insensitive): ALL, READ, WRITE, CREATE, DELETE, ALTER, DESCRIBE, CLUSTER_ACTION, DESCRIBE_CONFIGS, ALTER_CONFIGS, and IDEMPOTENT_WRITE. See https://kafka.apache.org/documentation/#operations_resources_and_pro tocols for valid combinations of resource_type and operation for different Kafka API requests. permissionType: Required. The permission type. Accepted values are (case insensitive): ALLOW, DENY. principal: Required. The principal. Specified as Google Cloud account, with the Kafka StandardAuthorizer prefix "User:". For example: "User:test-kafka-client@test-project.iam.gserviceaccount.com". Can be the wildcard "User:*" to refer to all users. r r r!r"rN) rrrrrrr&host operationpermissionType principalrrrrrrKsI&   q !$##A&)((+.##A&)rrcb\rSrSrSr\R "SS5r\R"S5r Sr g)AddAclEntryResponseezResponse for AddAclEntry. Fields: acl: The updated acl. aclCreated: Whether the acl was created as a result of adding the acl entry. rr r rN) rrrrrrracl BooleanField aclCreatedrrrrr3r3es+ ua(#%%a(*rr3c<\rSrSrSr\R "S5rSrg)BrokerCapacityConfigrzCapacity configuration at a per-broker level within the Kafka cluster. The config will be appled to each broker in the cluster. Fields: diskSizeGb: Optional. The disk to provision for each broker in Gigabytes. Minimum: 100 GB. r rN) rrrrrr IntegerField diskSizeGbrrrrr9r9rs%%a(*rr9c\rSrSrSr\R "S5r\R "S5r\R"S5r Sr g) BrokerDetails~zDetails of a broker in the Kafka cluster. Fields: brokerIndex: Output only. The index of the broker. nodeId: Output only. The node id of the broker. rack: Output only. The rack of the broker. r r r!rN) rrrrrrr; brokerIndexnodeIdr&rackrrrrr>r>~s9&&q)+  ! !! $&   q !$rr>c\rSrSrSrSrg)CancelOperationRequestz3The request message for Operations.CancelOperation.rNrrrrrrrrrrDrDsB*  " "1 %'rrQc^\rSrSrSr\R "S5r\R"SSS9r Sr g) CheckCompatibilityResponsezResponse for CheckCompatibility. Fields: is_compatible: The compatibility check result. If true, the schema is compatible with the resource. messages: Failure reasons if verbose = true. r r Tr rN) rrrrrrr6 is_compatibler&rrrrrrfrfs+((+-  " "1t 4(rrfc\rSrSrSr"SS\R 5r\R"S5"SS\R55r \R"S5"SS \R55r \R"S5"S S \R55r \R"S S 5r\R"SS5r\R"SSSS9r\R"S S5r\R"SS5r\R("S5r\R"SS5r\R"SS5r\R("S5r\R"S S5r\R("S5r\R"SS5r\R8"S 5r\R8"S!5r\R>"SS"5r \R"S#S$5r!\R"S%S&5r"\R("S'5r#S(r$g))*Clustera An Apache Kafka cluster deployed in a location. Enums: StateValueValuesEnum: Output only. The current state of the cluster. Messages: BrokerConfigOverridesValue: Optional. Configurations for the broker that are overridden from the cluster defaults. The key of the map is a Kafka broker property name, for example: `auto.create.topics.enable`. BrokersPerZoneValue: Output only. Only populated when FULL view is requested. The number of brokers per zone. LabelsValue: Optional. Labels as key value pairs. Fields: brokerCapacityConfig: Optional. Capacity configuration at a per-broker level within the Kafka cluster. The config will be appled to each broker in the cluster. brokerConfigOverrides: Optional. Configurations for the broker that are overridden from the cluster defaults. The key of the map is a Kafka broker property name, for example: `auto.create.topics.enable`. brokerDetails: Output only. Only populated when FULL view is requested. Details of each broker in the cluster. brokersPerZone: Output only. Only populated when FULL view is requested. The number of brokers per zone. capacityConfig: Required. Capacity configuration for the Kafka cluster. createTime: Output only. The time when the cluster was created. effectiveCapacityConfig: Output only. Only populated when FULL view is requested. The effective capacity configuration of the cluster. gcpConfig: Required. Configuration properties for a Kafka cluster deployed to Google Cloud Platform. kafkaVersion: Output only. Only populated when FULL view is requested. The Kafka version of the cluster. labels: Optional. Labels as key value pairs. name: Identifier. The name of the cluster. Structured like: projects/{project_number}/locations/{location}/clusters/{cluster_id} rebalanceConfig: Optional. Rebalance configuration for the Kafka cluster. satisfiesPzi: Output only. Reserved for future use. satisfiesPzs: Output only. Reserved for future use. state: Output only. The current state of the cluster. tlsConfig: Optional. TLS configuration for the Kafka cluster. updateOptions: Optional. UpdateOptions represents options that control how updates to the cluster are applied. updateTime: Output only. The time when the cluster was last updated. c(\rSrSrSrSrSrSrSrSr g) Cluster.StateValueValuesEnumi zOutput only. The current state of the cluster. Values: STATE_UNSPECIFIED: A state was not specified. CREATING: The cluster is being created. ACTIVE: The cluster is active. DELETING: The cluster is being deleted. rr r r!rN) rrrrrSTATE_UNSPECIFIEDCREATINGACTIVEDELETINGrrrrStateValueValuesEnumrm sH FHrrradditionalPropertiescf\rSrSrSr"SS\R 5r\R"SSSS9r Sr g ) "Cluster.BrokerConfigOverridesValueiaxOptional. Configurations for the broker that are overridden from the cluster defaults. The key of the map is a Kafka broker property name, for example: `auto.create.topics.enable`. Messages: AdditionalProperty: An additional property for a BrokerConfigOverridesValue object. Fields: additionalProperties: Additional properties of type BrokerConfigOverridesValue c`\rSrSrSr\R "S5r\R "S5rSr g)5Cluster.BrokerConfigOverridesValue.AdditionalPropertyi'zAn additional property for a BrokerConfigOverridesValue object. Fields: key: Name of the additional property. value: A string attribute. r r rN rrrrrrr&keyvaluerrrrAdditionalPropertyrw')   ! !! $c##A&err{r Tr rN rrrrrrMessager{rrsrrrrBrokerConfigOverridesValuerus2  'Y.. '%112FTXYrrcf\rSrSrSr"SS\R 5r\R"SSSS9r Sr g ) Cluster.BrokersPerZoneValuei4a Output only. Only populated when FULL view is requested. The number of brokers per zone. Messages: AdditionalProperty: An additional property for a BrokersPerZoneValue object. Fields: additionalProperties: Additional properties of type BrokersPerZoneValue c`\rSrSrSr\R "S5r\R"S5r Sr g).Cluster.BrokersPerZoneValue.AdditionalPropertyiAzAn additional property for a BrokersPerZoneValue object. Fields: key: Name of the additional property. value: A string attribute. r r rN) rrrrrrr&ryr;rzrrrrr{rAs)   ! !! $c$$Q'err{r Tr rNr}rrrBrokersPerZoneValuer4s2  (Y.. (%112FTXYrrcf\rSrSrSr"SS\R 5r\R"SSSS9r Sr g ) Cluster.LabelsValueiNOptional. Labels as key value pairs. Messages: AdditionalProperty: An additional property for a LabelsValue object. Fields: additionalProperties: Additional properties of type LabelsValue c`\rSrSrSr\R "S5r\R "S5rSr g)&Cluster.LabelsValue.AdditionalPropertyiYAn additional property for a LabelsValue object. Fields: key: Name of the additional property. value: A string attribute. r r rNrxrrrr{rYr|rr{r Tr rNr}rrr LabelsValuerN2 'Y.. '%112FTXYrrr9r r r>r!Tr r"rHr#r$EffectiveCapacityConfig GcpConfig RebalanceConfig  TlsConfig UpdateOptionsr rN)%rrrrrrr_rrrMapUnrecognizedFieldsr~rrrrbrokerCapacityConfigbrokerConfigOverrides brokerDetailsbrokersPerZonecapacityConfigr& createTimeeffectiveCapacityConfig gcpConfig kafkaVersionlabelsr(rebalanceConfigr6 satisfiesPzi satisfiesPzsrbstate tlsConfig updateOptions updateTimerrrrrjrjs+Z Y^^  !!"89Z9#4#4Z:Z6 !!"89ZI--Z:Z2 !!"89ZI%%Z:Z.#//0FJ#001MqQ((!dK-))*?C.))*:A>.$$Q'*%223LaP$$[!4)&&q),  ! !- 4&   r "$**+.  ! !- 3&$$Q'*$$%7;)&&q),  ! !- 3&   q !$''*,''*,   4b 9%$$R(*rrc`\rSrSrSr\R "SS5r\R"SSS9r Sr g ) riaConfiguration properties for a Kafka Connect cluster deployed to Google Cloud Platform. Fields: accessConfig: Required. Access configuration for the Kafka Connect cluster. secretPaths: Optional. Secrets to load into workers. Exact SecretVersions from Secret Manager must be provided -- aliases are not supported. Up to 32 secrets may be loaded into one cluster. Format: projects//secrets//versions/ rr r Tr rN) rrrrrrr accessConfigr& secretPathsrrrrrrs. ''(=qA,%%a$7+rrc\rSrSrSr\R "SSS9r\R "SSS9r\R "S5r Sr g ) ri aThe configuration of a Virtual Private Cloud (VPC) network that can access the Kafka Connect cluster. Fields: additionalSubnets: Optional. Additional subnets may be specified. They may be in another region, but must be in the same VPC network. The Connect workers can communicate with network endpoints in either the primary or additional subnets. dnsDomainNames: Optional. Additional DNS domain names from the subnet's network to be made visible to the Connect Cluster. When using MirrorMaker2, it's necessary to add the bootstrap address's dns domain name of the target cluster to make it visible to the connector. For example: my-kafka-cluster.us-central1.managedkafka.my-project.cloud.goog primarySubnet: Required. VPC subnet to make available to the Kafka Connect cluster. Structured like: projects/{project}/regions/{region}/subnetworks/{subnet_id} It is used to create a Private Service Connect (PSC) interface for the Kafka Connect workers. It must be located in the same region as the Kafka Connect cluster. The CIDR range of the subnet must be within the IPv4 address ranges for private networks, as specified in RFC 1918. The primary subnet CIDR range must have a minimum size of /22 (1024 addresses). r Tr r r!rN) rrrrrrr&additionalSubnetsdnsDomainNames primarySubnetrrrrrr s>0 ++A=((T:.''*-rrc,\rSrSrSr"SS\R 5r\R"S5"SS\R55r \R"SS5r \R"S 5r\R "SS 5r\R"S S 5rS rg) Connectori'a-A Kafka Connect connector in a given ConnectCluster. Enums: StateValueValuesEnum: Output only. The current state of the connector. Messages: ConfigsValue: Optional. Connector config as keys/values. The keys of the map are connector property names, for example: `connector.class`, `tasks.max`, `key.converter`. Fields: configs: Optional. Connector config as keys/values. The keys of the map are connector property names, for example: `connector.class`, `tasks.max`, `key.converter`. name: Identifier. The name of the connector. Structured like: projects/{pr oject}/locations/{location}/connectClusters/{connect_cluster}/connectors /{connector} state: Output only. The current state of the connector. taskRestartPolicy: Optional. Restarts the individual tasks of a Connector. c4\rSrSrSrSrSrSrSrSr Sr S r S r g ) Connector.StateValueValuesEnumi=aOutput only. The current state of the connector. Values: STATE_UNSPECIFIED: A state was not specified. UNASSIGNED: The connector is not assigned to any tasks, usually transient. RUNNING: The connector is running. PAUSED: The connector has been paused. FAILED: The connector has failed. See logs for why. RESTARTING: The connector is restarting. STOPPED: The connector has been stopped. rr r r!r"r#r$rN) rrrrrrn UNASSIGNEDRUNNINGPAUSEDFAILED RESTARTINGSTOPPEDrrrrrrr=s- JG F FJGrrrrscf\rSrSrSr"SS\R 5r\R"SSSS9r Sr g ) Connector.ConfigsValueiRa:Optional. Connector config as keys/values. The keys of the map are connector property names, for example: `connector.class`, `tasks.max`, `key.converter`. Messages: AdditionalProperty: An additional property for a ConfigsValue object. Fields: additionalProperties: Additional properties of type ConfigsValue c`\rSrSrSr\R "S5r\R "S5rSr g))Connector.ConfigsValue.AdditionalPropertyi_An additional property for a ConfigsValue object. Fields: key: Name of the additional property. value: A string attribute. r r rNrxrrrr{r_r|rr{r Tr rNr}rrr ConfigsValuerRrrrr r r!TaskRetryPolicyr"rN)rrrrrrr_rrrrr~rrconfigsr&r(rbrtaskRestartPolicyrrrrrr's*Y^^* !!"89ZY&&Z:Z2  " ">1 5'   q !$   4a 8%,,->Brrc\rSrSrSr\R "S5"SS\R55r \R"S5r \R"SS5r Srg ) ConsumerGroupiraA Kafka consumer group in a given cluster. Messages: TopicsValue: Optional. Metadata for this consumer group for all topics it has metadata for. The key of the map is a topic name, structured like: p rojects/{project}/locations/{location}/clusters/{cluster}/topics/{topic} Fields: name: Identifier. The name of the consumer group. The `consumer_group` segment is used when connecting directly to the cluster. Structured like: projects/{project}/locations/{location}/clusters/{cluster}/consume rGroups/{consumer_group} topics: Optional. Metadata for this consumer group for all topics it has metadata for. The key of the map is a topic name, structured like: proje cts/{project}/locations/{location}/clusters/{cluster}/topics/{topic} rscf\rSrSrSr"SS\R 5r\R"SSSS9r Sr g ) ConsumerGroup.TopicsValueiakOptional. Metadata for this consumer group for all topics it has metadata for. The key of the map is a topic name, structured like: projects/{project}/locations/{location}/clusters/{cluster}/topics/{topic} Messages: AdditionalProperty: An additional property for a TopicsValue object. Fields: additionalProperties: Additional properties of type TopicsValue cb\rSrSrSr\R "S5r\R"SS5r Sr g),ConsumerGroup.TopicsValue.AdditionalPropertyizAn additional property for a TopicsValue object. Fields: key: Name of the additional property. value: A ConsumerTopicMetadata attribute. r ConsumerTopicMetadatar rN rrrrrrr&ryrrzrrrrr{r,   ! !! $c$$%.**1-rrch\rSrSrSr"SS\R 5r\R"S\RRS9r \R"S5r \R"SS S S 9r\R "S 5r\R$"SS 5r\R"S\RRS9rSrg)CreateVersionRequestia Request for CreateVersion. Enums: SchemaTypeValueValuesEnum: Optional. The type of the schema. It is optional. If not specified, the schema type will be AVRO. Fields: id: Optional. The schema ID of the schema. If not specified, the schema ID will be generated by the server. If the schema ID is specified, it must not be used by an existing schema that is different from the schema to be created. normalize: Optional. If true, the schema will be normalized before being stored. The default is false. references: Optional. The schema references used by the schema. schema: Required. The schema payload schemaType: Optional. The type of the schema. It is optional. If not specified, the schema type will be AVRO. version: Optional. The version to create. It is optional. If not specified, the version will be created with the max version ID of the subject increased by 1. If the version ID is specified, it will be used as the new version ID and must not be used by an existing version of the subject. c(\rSrSrSrSrSrSrSrSr g) .CreateVersionRequest.SchemaTypeValueValuesEnumiaOptional. The type of the schema. It is optional. If not specified, the schema type will be AVRO. Values: SCHEMA_TYPE_UNSPECIFIED: No schema type. The default will be AVRO. AVRO: Avro schema type. JSON: JSON schema type. PROTOBUF: Protobuf schema type. rr r r!rNrWrrrr\rs  D DHrr\r variantr r^r!Tr r"r#r$rN)rrrrrrr_r\r;VariantINT32idr6 normalizerr`r&rarbrcversionrrrrrrs0 ).. a):):)@)@A"$$Q')%%&7TJ*   #&""#>B*  " "1i.?.?.E.E F'rrcb\rSrSrSr\R "S\RRS9r Sr g)CreateVersionResponsei*zXResponse for CreateVersion. Fields: id: The unique identifier of the schema created. r rrN) rrrrrrr;rrrrrrrr r *s' a):):)@)@A"rr c`\rSrSrSr\R "S5r\R "S5rSr g)ri4aDescribes the effective capacity configuration of a Kafka cluster, both cluster-wide and per-broker. Fields: brokerCount: Output only. The number of brokers in the cluster. brokerDiskSizeGb: Output only. The disk assigned to each broker in Gigabytes. r r rN) rrrrrrr; brokerCountbrokerDiskSizeGbrrrrrr4s*&&q)+++A.rrc\rSrSrSrSrg)EmptyiBaA generic empty message that you can re-use to avoid defining duplicated empty messages in your APIs. A typical example is to use it as the request or the response type of an API method. For instance: service Foo { rpc Bar(google.protobuf.Empty) returns (google.protobuf.Empty); } rNrFrrrrrBsrrcb\rSrSrSr\R "SS5r\R"S5r Sr g)riKaConfiguration properties for a Kafka cluster deployed to Google Cloud Platform. Fields: accessConfig: Required. Access configuration for the Kafka cluster. kmsKey: Optional. Immutable. The Cloud KMS Key name to use for encryption. The key must be located in the same region as the cluster and cannot be changed. Structured like: projects/{project}/locations/{location}/keyRin gs/{key_ring}/cryptoKeys/{crypto_key}. r r r rN) rrrrrrrrr&kmsKeyrrrrrrKs+ '':,   #&rrc\rSrSrSr\R "S5"SS\R55r \R"S5r \R"S5r \R"SSS S 9rS rg ) HttpBodyi[aMessage that represents an arbitrary HTTP body. It should only be used for payload formats that can't be represented as JSON, such as raw binary or an HTML page. This message can be used both in streaming and non-streaming API methods in the request as well as the response. It can be used as a top- level request field, which is convenient if one wants to extract parameters from either the URL or HTTP template into the request fields and also want access to the raw HTTP body. Example: message GetResourceRequest { // A unique request id. string request_id = 1; // The raw HTTP body is bound to this field. google.api.HttpBody http_body = 2; } service ResourceService { rpc GetResource(GetResourceRequest) returns (google.api.HttpBody); rpc UpdateResource(google.api.HttpBody) returns (google.protobuf.Empty); } Example with streaming methods: service CaldavService { rpc GetCalendar(stream google.api.HttpBody) returns (stream google.api.HttpBody); rpc UpdateCalendar(stream google.api.HttpBody) returns (stream google.api.HttpBody); } Use of this type only changes how the request and response bodies are handled, all other features will continue to work unchanged. Messages: ExtensionsValueListEntry: A ExtensionsValueListEntry object. Fields: contentType: The HTTP Content-Type header value specifying the content type of the body. data: The HTTP request/response body as raw binary. extensions: Application specific response metadata. Must be set in the first response for streaming APIs. rscf\rSrSrSr"SS\R 5r\R"SSSS9r Sr g ) !HttpBody.ExtensionsValueListEntryiyzA ExtensionsValueListEntry object. Messages: AdditionalProperty: An additional property for a ExtensionsValueListEntry object. Fields: additionalProperties: Properties of the object. Contains field @type with type URL. cb\rSrSrSr\R "S5r\R"SS5r Sr g)4HttpBody.ExtensionsValueListEntry.AdditionalPropertyizAn additional property for a ExtensionsValueListEntry object. Fields: key: Name of the additional property. value: A extra_types.JsonValue attribute. r extra_types.JsonValuer rNrrrrr{rrrr{r Tr rNr}rrrExtensionsValueListEntryryrrrr r r!Tr rN)rrrrrrrrr~rr& contentType BytesFielddatar extensionsrrrrrr[sn: !!"89Z!2!2Z:Z2%%a(+   a $%%&@!dS*rrc`\rSrSrSr\R "SSSS9r\R"S5r Sr g ) ListAclsResponseiaResponse for ListAcls. Fields: acls: The list of acls in the requested parent. The order of the acls is unspecified. nextPageToken: A token that can be sent as `page_token` to retrieve the next page of results. If this field is omitted, there are no more results. rr Tr r rN) rrrrrrraclsr& nextPageTokenrrrrrrs-   q4 8$''*-rrc\rSrSrSr\R "SSSS9r\R"S5r \R"SSS9r S r g ) ListClustersResponseia/Response for ListClusters. Fields: clusters: The list of Clusters in the requested parent. nextPageToken: A token that can be sent as `page_token` to retrieve the next page of results. If this field is omitted, there are no more results. unreachable: Locations that could not be reached. rjr Tr r r!rN) rrrrrrrclustersr&r  unreachablerrrrr"r"s? # #Iq4 @(''*-%%a$7+rr"c\rSrSrSr\R "SSSS9r\R"S5r \R"SSS9r S r g ) ListConnectClustersResponseiaEResponse for ListConnectClusters. Fields: connectClusters: The list of Connect clusters in the requested parent. nextPageToken: A token that can be sent as `page_token` to retrieve the next page of results. If this field is omitted, there are no more results. unreachable: Locations that could not be reached. rr Tr r r!rN) rrrrrrrconnectClustersr&r r$rrrrr&r&s@**+;QN/''*-%%a$7+rr&c`\rSrSrSr\R "SSSS9r\R"S5r Sr g ) ListConnectorsResponseiaResponse for ListConnectors. Fields: connectors: The list of connectors in the requested parent. nextPageToken: A token that can be sent as `page_token` to retrieve the next page of results. If this field is omitted, there are no more results. rr Tr r rN) rrrrrrr connectorsr&r rrrrr)r)s-%%k1tD*''*-rr)c`\rSrSrSr\R "SSSS9r\R"S5r Sr g ) ListConsumerGroupsResponseiaBResponse for ListConsumerGroups. Fields: consumerGroups: The list of consumer group in the requested parent. The order of the consumer groups is unspecified. nextPageToken: A token that can be sent as `page_token` to retrieve the next page of results. If this field is omitted, there are no more results. rr Tr r rN) rrrrrrrconsumerGroupsr&r rrrrr,r,s-))/1tL.''*-rr,c`\rSrSrSr\R "SSSS9r\R"S5r Sr g ) ListLocationsResponseizThe response message for Locations.ListLocations. Fields: locations: A list of locations that matches the specified filter in the request. nextPageToken: The standard List next-page token. Locationr Tr r rN) rrrrrrr locationsr&r rrrrr/r/s-$$ZTB)''*-rr/c\rSrSrSr\R "S5r\R"SSSS9r \R "SSS9r S r g ) ListOperationsResponseiaThe response message for Operations.ListOperations. Fields: nextPageToken: The standard List next-page token. operations: A list of operations that matches the specified filter in the request. unreachable: Unordered list. Unreachable resources. Populated when the request sets `ListOperationsRequest.return_partial_success` and reads across collections e.g. when attempting to list all resources across all supported locations. r Operationr Tr r!rN) rrrrrrr&r r operationsr$rrrrr3r3s? ''*-%%k1tD*%%a$7+rr3c<\rSrSrSr\R "SSSS9rSrg) ListSchemaRegistriesResponseiz^Request for ListSchemaRegistries. Fields: schemaRegistries: The schema registry instances. rr Tr rN) rrrrrrrschemaRegistriesrrrrr7r7s ++,rr r rNrxrrrr{r@>r|rr{r Tr rNr}rrrrr>2s2 'Y.. '%112FTXYrrcf\rSrSrSr"SS\R 5r\R"SSSS9r Sr g ) Location.MetadataValueiKa Service-specific metadata. For example the available capacity at the given location. Messages: AdditionalProperty: An additional property for a MetadataValue object. Fields: additionalProperties: Properties of the object. Contains field @type with type URL. cb\rSrSrSr\R "S5r\R"SS5r Sr g))Location.MetadataValue.AdditionalPropertyiXAn additional property for a MetadataValue object. Fields: key: Name of the additional property. value: A extra_types.JsonValue attribute. r rr rNrrrrr{rDXrrr{r Tr rNr}rrr MetadataValuerBKrrrFr r r!r"r#rN)rrrrrrrrr~rrFr& displayNamerr locationIdrr(rrrrr0r0s* !!"89ZI%%Z:Z0 !!"89Zi''Z:Z2%%a(+  ! !- 3&$$Q'*  # #OQ 7(   q !$rr0c\rSrSrSr"SS\R 5r\R"S5r \R"S5r \R"SSS S 9r \R"S 5r\R"SS 5rS rg)LookupVersionRequestilaVRequest for LookupVersion. Enums: SchemaTypeValueValuesEnum: Optional. The schema type of the schema. Fields: deleted: Optional. If true, soft-deleted versions will be included in lookup, no matter if the subject is active or soft-deleted. If false, soft-deleted versions will be excluded. The default is false. normalize: Optional. If true, the schema will be normalized before being looked up. The default is false. references: Optional. The schema references used by the schema. schema: Required. The schema payload schemaType: Optional. The schema type of the schema. c(\rSrSrSrSrSrSrSrSr g) .LookupVersionRequest.SchemaTypeValueValuesEnumi}rVrr r r!rNrWrrrr\rL}r]rr\r r r^r!Tr r"r#rN)rrrrrrr_r\r6deletedrrr`r&rarbrcrrrrrJrJlsq )..   " "1 %'$$Q')%%&7TJ*   #&""#>B*rrJc`\rSrSrSr\R "SSS9r\R"SS5r Sr g ) ;ManagedkafkaProjectsLocationsClustersAclsAddAclEntryRequestiaA ManagedkafkaProjectsLocationsClustersAclsAddAclEntryRequest object. Fields: acl: Required. The name of the acl to add the acl entry to. Structured like: `projects/{project}/locations/{location}/clusters/{cluster}/acls/{ acl_id}`. The structure of `acl_id` defines the Resource Pattern (resource_type, resource_name, pattern_type) of the acl. See `Acl.name` for details. aclEntry: A AclEntry resource to be passed as the request body. r Trequiredrr rN rrrrrrr&r5raclEntryrrrrrOrO-  a$/#  # #J 2(rrOc\rSrSrSr\R "SS5r\R"S5r \R"SSS9r S r g ) 6ManagedkafkaProjectsLocationsClustersAclsCreateRequestia|A ManagedkafkaProjectsLocationsClustersAclsCreateRequest object. Fields: acl: A Acl resource to be passed as the request body. aclId: Required. The ID to use for the acl, which will become the final component of the acl's name. The structure of `acl_id` defines the Resource Pattern (resource_type, resource_name, pattern_type) of the acl. `acl_id` is structured like one of the following: For acls on the cluster: `cluster` For acls on a single resource within the cluster: `topic/{resource_name}` `consumerGroup/{resource_name}` `transactionalId/{resource_name}` For acls on all resources that match a prefix: `topicPrefixed/{resource_name}` `consumerGroupPrefixed/{resource_name}` `transactionalIdPrefixed/{resource_name}` For acls on all resources of a given type (i.e. the wildcard literal "*"): `allTopics` (represents `topic/*`) `allConsumerGroups` (represents `consumerGroup/*`) `allTransactionalIds` (represents `transactionalId/*`) parent: Required. The parent cluster in which to create the acl. Structured like `projects/{project}/locations/{location}/clusters/{cluster}`. rr r r!TrPrN) rrrrrrrr5r&aclIdparentrrrrrVrVs=, ua(#    "%  T 2&rrVc:\rSrSrSr\R "SSS9rSrg)6ManagedkafkaProjectsLocationsClustersAclsDeleteRequestiaqA ManagedkafkaProjectsLocationsClustersAclsDeleteRequest object. Fields: name: Required. The name of the acl to delete. Structured like: `projects/ {project}/locations/{location}/clusters/{cluster}/acls/{acl_id}`. The structure of `acl_id` defines the Resource Pattern (resource_type, resource_name, pattern_type) of the acl. See `Acl.name` for details. r TrPrN rrrrrrr&r(rrrrrZrZ   q4 0$rrZc:\rSrSrSr\R "SSS9rSrg)3ManagedkafkaProjectsLocationsClustersAclsGetRequestianA ManagedkafkaProjectsLocationsClustersAclsGetRequest object. Fields: name: Required. The name of the acl to return. Structured like: `projects/ {project}/locations/{location}/clusters/{cluster}/acls/{acl_id}`. The structure of `acl_id` defines the Resource Pattern (resource_type, resource_name, pattern_type) of the acl. See `Acl.name` for details. r TrPrNr[rrrr^r^r\rr^c\rSrSrSr\R "S\RRS9r \R"S5r \R"SSS9r S r g ) 4ManagedkafkaProjectsLocationsClustersAclsListRequestiaA ManagedkafkaProjectsLocationsClustersAclsListRequest object. Fields: pageSize: Optional. The maximum number of acls to return. The service may return fewer than this value. If unset or zero, all acls for the parent is returned. pageToken: Optional. A page token, received from a previous `ListAcls` call. Provide this to retrieve the subsequent page. When paginating, all other parameters provided to `ListAcls` must match the call that provided the page token. parent: Required. The parent cluster whose acls are to be listed. Structured like `projects/{project}/locations/{location}/clusters/{cluster}`. r rr r!TrPrNrrrrrrr;rrpageSizer& pageTokenrXrrrrr`r`I  # #Ay/@/@/F/F G(##A&)  T 2&rr`c\rSrSrSr\R "SS5r\R"SSS9r \R"S5r S r g ) 5ManagedkafkaProjectsLocationsClustersAclsPatchRequestia9A ManagedkafkaProjectsLocationsClustersAclsPatchRequest object. Fields: acl: A Acl resource to be passed as the request body. name: Identifier. The name for the acl. Represents a single Resource Pattern. Structured like: projects/{project}/locations/{location}/clusters/{cluster}/acls/{acl_id} The structure of `acl_id` defines the Resource Pattern (resource_type, resource_name, pattern_type) of the acl. `acl_id` is structured like one of the following: For acls on the cluster: `cluster` For acls on a single resource within the cluster: `topic/{resource_name}` `consumerGroup/{resource_name}` `transactionalId/{resource_name}` For acls on all resources that match a prefix: `topicPrefixed/{resource_name}` `consumerGroupPrefixed/{resource_name}` `transactionalIdPrefixed/{resource_name}` For acls on all resources of a given type (i.e. the wildcard literal "*"): `allTopics` (represents `topic/*`) `allConsumerGroups` (represents `consumerGroup/*`) `allTransactionalIds` (represents `transactionalId/*`) updateMask: Optional. Field mask is used to specify the fields to be overwritten in the Acl resource by the update. The fields specified in the update_mask are relative to the resource, not the full request. A field will be overwritten if it is in the mask. rr r TrPr!rN) rrrrrrrr5r&r( updateMaskrrrrrfrfs=0 ua(#   q4 0$$$Q'*rrfc`\rSrSrSr\R "SSS9r\R"SS5r Sr g ) >ManagedkafkaProjectsLocationsClustersAclsRemoveAclEntryRequesti aA ManagedkafkaProjectsLocationsClustersAclsRemoveAclEntryRequest object. Fields: acl: Required. The name of the acl to remove the acl entry from. Structured like: `projects/{project}/locations/{location}/clusters/{clus ter}/acls/{acl_id}`. The structure of `acl_id` defines the Resource Pattern (resource_type, resource_name, pattern_type) of the acl. See `Acl.name` for details. aclEntry: A AclEntry resource to be passed as the request body. r TrPrr rNrRrrrriri rTrric:\rSrSrSr\R "SSS9rSrg)@ManagedkafkaProjectsLocationsClustersConsumerGroupsDeleteRequestizA ManagedkafkaProjectsLocationsClustersConsumerGroupsDeleteRequest object. Fields: name: Required. The name of the consumer group to delete. `projects/{proje ct}/locations/{location}/clusters/{cluster}/consumerGroups/{consumerGrou p}`. r TrPrNr[rrrrkrkr\rrkc:\rSrSrSr\R "SSS9rSrg)=ManagedkafkaProjectsLocationsClustersConsumerGroupsGetRequesti(aA ManagedkafkaProjectsLocationsClustersConsumerGroupsGetRequest object. Fields: name: Required. The name of the consumer group whose configuration to return. `projects/{project}/locations/{location}/clusters/{cluster}/cons umerGroups/{consumerGroup}`. r TrPrNr[rrrrmrm(   q4 0$rrmc\rSrSrSr"SS\R 5r\R"S5r \R"S\RRS9r \R"S5r\R"S S S 9r\R "SS 5rS rg)>ManagedkafkaProjectsLocationsClustersConsumerGroupsListRequesti4a3A ManagedkafkaProjectsLocationsClustersConsumerGroupsListRequest object. Enums: ViewValueValuesEnum: Optional. Specifies which parts of the ConsumerGroup resource should be returned in the response. Fields: filter: Optional. Filter expression for the result. Only supports filtering by topic name as a key in the `topics` map. pageSize: Optional. The maximum number of consumer groups to return. The service may return fewer than this value. If unset or zero, all consumer groups for the parent is returned. pageToken: Optional. A page token, received from a previous `ListConsumerGroups` call. Provide this to retrieve the subsequent page. When paginating, all other parameters provided to `ListConsumerGroups` must match the call that provided the page token. parent: Required. The parent cluster whose consumer groups are to be listed. Structured like `projects/{project}/locations/{location}/clusters/{cluster}`. view: Optional. Specifies which parts of the ConsumerGroup resource should be returned in the response. c$\rSrSrSrSrSrSrSrg)RManagedkafkaProjectsLocationsClustersConsumerGroupsListRequest.ViewValueValuesEnumiLaOptional. Specifies which parts of the ConsumerGroup resource should be returned in the response. Values: CONSUMER_GROUP_VIEW_UNSPECIFIED: The default / unset value. The API will default to the FULL view. CONSUMER_GROUP_VIEW_BASIC: Include the name of the ConsumerGroup. This hides partition and topic metadata. CONSUMER_GROUP_VIEW_FULL: Include everything, including partition and topic metadata. This is the default value. rr r rN) rrrrrCONSUMER_GROUP_VIEW_UNSPECIFIEDCONSUMER_GROUP_VIEW_BASICCONSUMER_GROUP_VIEW_FULLrrrrViewValueValuesEnumrrLs '(# ! rrvr r rr!r"TrPr#rN)rrrrrrr_rvr&filterr;rrrbrcrXrbviewrrrrrprp4s|.!INN!   #&  # #Ay/@/@/F/F G(##A&)  T 2&   2A 6$rrpc\rSrSrSr\R "SS5r\R"SSS9r \R"S5r S r g ) ?ManagedkafkaProjectsLocationsClustersConsumerGroupsPatchRequesticaA ManagedkafkaProjectsLocationsClustersConsumerGroupsPatchRequest object. Fields: consumerGroup: A ConsumerGroup resource to be passed as the request body. name: Identifier. The name of the consumer group. The `consumer_group` segment is used when connecting directly to the cluster. Structured like: projects/{project}/locations/{location}/clusters/{cluster}/consume rGroups/{consumer_group} updateMask: Required. Field mask is used to specify the fields to be overwritten in the ConsumerGroup resource by the update. The fields specified in the update_mask are relative to the resource, not the full request. A field will be overwritten if it is in the mask. The mask is required and a value of * will update all fields. rr r TrPr!rN) rrrrrrr consumerGroupr&r(rgrrrrrzrzcs= ((!<-   q4 0$$$Q'*rrzc\rSrSrSr\R "SS5r\R"S5r \R"SSS9r \R"S 5r S r g ) 2ManagedkafkaProjectsLocationsClustersCreateRequestiyaKA ManagedkafkaProjectsLocationsClustersCreateRequest object. Fields: cluster: A Cluster resource to be passed as the request body. clusterId: Required. The ID to use for the cluster, which will become the final component of the cluster's name. The ID must be 1-63 characters long, and match the regular expression `[a-z]([-a-z0-9]*[a-z0-9])?` to comply with RFC 1035. This value is structured like: `my-cluster-id`. parent: Required. The parent region in which to create the cluster. Structured like `projects/{project}/locations/{location}`. requestId: Optional. An optional request ID to identify requests. Specify a unique request ID to avoid duplication of requests. If a request times out or fails, retrying with the same ID allows the server to recognize the previous attempt. For at least 60 minutes, the server ignores duplicate requests bearing the same ID. For example, consider a situation where you make an initial request and the request times out. If you make the request again with the same request ID within 60 minutes of the last request, the server checks if an original operation with the same request ID was received. If so, the server ignores the second request. The request ID must be a valid UUID. A zero UUID is not supported (00000000-0000-0000-0000-000000000000). rjr r r!TrPr"rN) rrrrrrrclusterr& clusterIdrX requestIdrrrrr}r}ysM.  " "9a 0'##A&)  T 2&##A&)rr}c^\rSrSrSr\R "SSS9r\R "S5rSr g) 2ManagedkafkaProjectsLocationsClustersDeleteRequestiaA ManagedkafkaProjectsLocationsClustersDeleteRequest object. Fields: name: Required. The name of the cluster to delete. requestId: Optional. An optional request ID to identify requests. Specify a unique request ID to avoid duplication of requests. If a request times out or fails, retrying with the same ID allows the server to recognize the previous attempt. For at least 60 minutes, the server ignores duplicate requests bearing the same ID. For example, consider a situation where you make an initial request and the request times out. If you make the request again with the same request ID within 60 minutes of the last request, the server checks if an original operation with the same request ID was received. If so, the server ignores the second request. The request ID must be a valid UUID. A zero UUID is not supported (00000000-0000-0000-0000-000000000000). r TrPr rN rrrrrrr&r(rrrrrrrs+"   q4 0$##A&)rrc\rSrSrSr"SS\R 5r\R"SSS9r \R"SS5r S r g ) /ManagedkafkaProjectsLocationsClustersGetRequestiasA ManagedkafkaProjectsLocationsClustersGetRequest object. Enums: ViewValueValuesEnum: Optional. Specifies which parts of the Cluster resource should be returned in the response. Fields: name: Required. The name of the cluster whose configuration to return. view: Optional. Specifies which parts of the Cluster resource should be returned in the response. c$\rSrSrSrSrSrSrSrg)CManagedkafkaProjectsLocationsClustersGetRequest.ViewValueValuesEnumiaOptional. Specifies which parts of the Cluster resource should be returned in the response. Values: CLUSTER_VIEW_UNSPECIFIED: The default / unset value. The API will default to the BASIC view. CLUSTER_VIEW_BASIC: Include the basic metadata of the Cluster. This is the default value (for both ListClusters and GetCluster). CLUSTER_VIEW_FULL: Include everything, including data fetched from the Kafka cluster source of truth. rr r rN) rrrrrCLUSTER_VIEW_UNSPECIFIEDCLUSTER_VIEW_BASICCLUSTER_VIEW_FULLrrrrrvrs  !rrvr TrPr rN) rrrrrrr_rvr&r(rbrxrrrrrrs> INN   q4 0$   2A 6$rrc\rSrSrSr\R "S5r\R "S5r\R"S\RRS9r \R "S5r \R "SS S 9rS rg ) 0ManagedkafkaProjectsLocationsClustersListRequestiaA ManagedkafkaProjectsLocationsClustersListRequest object. Fields: filter: Optional. Filter expression for the result. orderBy: Optional. Order by fields for the result. pageSize: Optional. The maximum number of clusters to return. The service may return fewer than this value. If unspecified, server will pick an appropriate default. pageToken: Optional. A page token, received from a previous `ListClusters` call. Provide this to retrieve the subsequent page. When paginating, all other parameters provided to `ListClusters` must match the call that provided the page token. parent: Required. The parent location whose clusters are to be listed. Structured like `projects/{project}/locations/{location}`. r r r!rr"r#TrPrNrrrrrrr&rworderByr;rrrbrcrXrrrrrri   #&  ! !! $'  # #Ay/@/@/F/F G(##A&)  T 2&rrc\rSrSrSr\R "SS5r\R"SSS9r \R"S5r \R"S 5r S r g ) 1ManagedkafkaProjectsLocationsClustersPatchRequestiawA ManagedkafkaProjectsLocationsClustersPatchRequest object. Fields: cluster: A Cluster resource to be passed as the request body. name: Identifier. The name of the cluster. Structured like: projects/{project_number}/locations/{location}/clusters/{cluster_id} requestId: Optional. An optional request ID to identify requests. Specify a unique request ID to avoid duplication of requests. If a request times out or fails, retrying with the same ID allows the server to recognize the previous attempt. For at least 60 minutes, the server ignores duplicate requests bearing the same ID. For example, consider a situation where you make an initial request and the request times out. If you make the request again with the same request ID within 60 minutes of the last request, the server checks if an original operation with the same request ID was received. If so, the server ignores the second request. The request ID must be a valid UUID. A zero UUID is not supported (00000000-0000-0000-0000-000000000000). updateMask: Required. Field mask is used to specify the fields to be overwritten in the cluster resource by the update. The fields specified in the update_mask are relative to the resource, not the full request. A field will be overwritten if it is in the mask. The mask is required and a value of * will update all fields. rjr r TrPr!r"rN) rrrrrrrr~r&r(rrgrrrrrrsM0  " "9a 0'   q4 0$##A&)$$Q'*rrc\rSrSrSr\R "SSS9r\R"SS5r \R "S5r S r g ) 8ManagedkafkaProjectsLocationsClustersTopicsCreateRequestiaA ManagedkafkaProjectsLocationsClustersTopicsCreateRequest object. Fields: parent: Required. The parent cluster in which to create the topic. Structured like `projects/{project}/locations/{location}/clusters/{cluster}`. topic: A Topic resource to be passed as the request body. topicId: Required. The ID to use for the topic, which will become the final component of the topic's name. This value is structured like: `my- topic-name`. r TrPr;r r!rN) rrrrrrr&rXrtopictopicIdrrrrrrs=   T 2&  ! ,%  ! !! $'rrc:\rSrSrSr\R "SSS9rSrg)8ManagedkafkaProjectsLocationsClustersTopicsDeleteRequestizA ManagedkafkaProjectsLocationsClustersTopicsDeleteRequest object. Fields: name: Required. The name of the topic to delete. `projects/{project}/locat ions/{location}/clusters/{cluster}/topics/{topic}`. r TrPrNr[rrrrrs   q4 0$rrc:\rSrSrSr\R "SSS9rSrg)5ManagedkafkaProjectsLocationsClustersTopicsGetRequesti"zA ManagedkafkaProjectsLocationsClustersTopicsGetRequest object. Fields: name: Required. The name of the topic whose configuration to return. Structured like: projects/{project}/locations/{location}/clusters/{clust er}/topics/{topic}. r TrPrNr[rrrrr"rnrrc\rSrSrSr\R "S\RRS9r \R"S5r \R"SSS9r S r g ) 6ManagedkafkaProjectsLocationsClustersTopicsListRequesti.aA ManagedkafkaProjectsLocationsClustersTopicsListRequest object. Fields: pageSize: Optional. The maximum number of topics to return. The service may return fewer than this value. If unset or zero, all topics for the parent is returned. pageToken: Optional. A page token, received from a previous `ListTopics` call. Provide this to retrieve the subsequent page. When paginating, all other parameters provided to `ListTopics` must match the call that provided the page token. parent: Required. The parent cluster whose topics are to be listed. Structured like `projects/{project}/locations/{location}/clusters/{cluster}`. r rr r!TrPrNrarrrrr.rdrrc\rSrSrSr\R "SSS9r\R"SS5r \R "S5r S r g ) 7ManagedkafkaProjectsLocationsClustersTopicsPatchRequestiCaA ManagedkafkaProjectsLocationsClustersTopicsPatchRequest object. Fields: name: Identifier. The name of the topic. The `topic` segment is used when connecting directly to the cluster. Structured like: projects/{project}/ locations/{location}/clusters/{cluster}/topics/{topic} topic: A Topic resource to be passed as the request body. updateMask: Required. Field mask is used to specify the fields to be overwritten in the Topic resource by the update. The fields specified in the update_mask are relative to the resource, not the full request. A field will be overwritten if it is in the mask. The mask is required and a value of * will update all fields. r TrPr;r r!rN) rrrrrrr&r(rrrgrrrrrrCs=    q4 0$  ! ,%$$Q'*rrc\rSrSrSr\R "SS5r\R"S5r \R"SSS9r S r g ) CManagedkafkaProjectsLocationsConnectClustersConnectorsCreateRequestiWaA ManagedkafkaProjectsLocationsConnectClustersConnectorsCreateRequest object. Fields: connector: A Connector resource to be passed as the request body. connectorId: Required. The ID to use for the connector, which will become the final component of the connector's name. The ID must be 1-63 characters long, and match the regular expression `[a-z]([-a-z0-9]*[a-z0-9])?` to comply with RFC 1035. This value is structured like: `my-connector-id`. parent: Required. The parent Connect cluster in which to create the connector. Structured like `projects/{project}/locations/{location}/conn ectClusters/{connect_cluster_id}`. rr r r!TrPrN) rrrrrrr connectorr& connectorIdrXrrrrrrWs= $$[!4)%%a(+  T 2&rrc:\rSrSrSr\R "SSS9rSrg)CManagedkafkaProjectsLocationsConnectClustersConnectorsDeleteRequestila A ManagedkafkaProjectsLocationsConnectClustersConnectorsDeleteRequest object. Fields: name: Required. The name of the connector to delete. Structured like: proj ects/{project}/locations/{location}/connectClusters/{connectCluster}/con nectors/{connector} r TrPrNr[rrrrrlr\rrc:\rSrSrSr\R "SSS9rSrg)@ManagedkafkaProjectsLocationsConnectClustersConnectorsGetRequestiyaA ManagedkafkaProjectsLocationsConnectClustersConnectorsGetRequest object. Fields: name: Required. The name of the connector whose configuration to return. Structured like: projects/{project}/locations/{location}/connectClusters /{connectCluster}/connectors/{connector} r TrPrNr[rrrrryr\rrc\rSrSrSr\R "S\RRS9r \R"S5r \R"SSS9r S r g ) AManagedkafkaProjectsLocationsConnectClustersConnectorsListRequestiaA ManagedkafkaProjectsLocationsConnectClustersConnectorsListRequest object. Fields: pageSize: Optional. The maximum number of connectors to return. The service may return fewer than this value. If unspecified, server will pick an appropriate default. pageToken: Optional. A page token, received from a previous `ListConnectors` call. Provide this to retrieve the subsequent page. When paginating, all other parameters provided to `ListConnectors` must match the call that provided the page token. parent: Required. The parent Connect cluster whose connectors are to be listed. Structured like `projects/{project}/locations/{location}/connect Clusters/{connect_cluster_id}`. r rr r!TrPrNrarrrrrsI  # #Ay/@/@/F/F G(##A&)  T 2&rrc\rSrSrSr\R "SS5r\R"SSS9r \R"S5r S r g ) BManagedkafkaProjectsLocationsConnectClustersConnectorsPatchRequestiaA ManagedkafkaProjectsLocationsConnectClustersConnectorsPatchRequest object. Fields: connector: A Connector resource to be passed as the request body. name: Identifier. The name of the connector. Structured like: projects/{pr oject}/locations/{location}/connectClusters/{connect_cluster}/connectors /{connector} updateMask: Required. Field mask is used to specify the fields to be overwritten in the cluster resource by the update. The fields specified in the update_mask are relative to the resource, not the full request. A field will be overwritten if it is in the mask. The mask is required and a value of * will update all fields. rr r TrPr!rN) rrrrrrrrr&r(rgrrrrrrs= $$[!4)   q4 0$$$Q'*rrc`\rSrSrSr\R "SSS9r\R"SS5r Sr g ) BManagedkafkaProjectsLocationsConnectClustersConnectorsPauseRequestiagA ManagedkafkaProjectsLocationsConnectClustersConnectorsPauseRequest object. Fields: name: Required. The name of the connector to pause. Structured like: proje cts/{project}/locations/{location}/connectClusters/{connectCluster}/conn ectors/{connector} pauseConnectorRequest: A PauseConnectorRequest resource to be passed as the request body. r TrPPauseConnectorRequestr rN) rrrrrrr&r(rpauseConnectorRequestrrrrrrs/    q4 0$#001H!Lrrc`\rSrSrSr\R "SSS9r\R"SS5r Sr g ) DManagedkafkaProjectsLocationsConnectClustersConnectorsRestartRequestiaoA ManagedkafkaProjectsLocationsConnectClustersConnectorsRestartRequest object. Fields: name: Required. The name of the connector to restart. Structured like: pro jects/{project}/locations/{location}/connectClusters/{connectCluster}/co nnectors/{connector} restartConnectorRequest: A RestartConnectorRequest resource to be passed as the request body. r TrPRestartConnectorRequestr rN) rrrrrrr&r(rrestartConnectorRequestrrrrrrs/    q4 0$%223LaPrrc`\rSrSrSr\R "SSS9r\R"SS5r Sr g ) CManagedkafkaProjectsLocationsConnectClustersConnectorsResumeRequestiajA ManagedkafkaProjectsLocationsConnectClustersConnectorsResumeRequest object. Fields: name: Required. The name of the connector to pause. Structured like: proje cts/{project}/locations/{location}/connectClusters/{connectCluster}/conn ectors/{connector} resumeConnectorRequest: A ResumeConnectorRequest resource to be passed as the request body. r TrPResumeConnectorRequestr rN) rrrrrrr&r(rresumeConnectorRequestrrrrrrs/    q4 0$$112JANrrc`\rSrSrSr\R "SSS9r\R"SS5r Sr g ) AManagedkafkaProjectsLocationsConnectClustersConnectorsStopRequestiacA ManagedkafkaProjectsLocationsConnectClustersConnectorsStopRequest object. Fields: name: Required. The name of the connector to stop. Structured like: projec ts/{project}/locations/{location}/connectClusters/{connectCluster}/conne ctors/{connector} stopConnectorRequest: A StopConnectorRequest resource to be passed as the request body. r TrPStopConnectorRequestr rN) rrrrrrr&r(rstopConnectorRequestrrrrrrs/    q4 0$"//0FJrrc\rSrSrSr\R "SS5r\R"S5r \R"SSS9r \R"S 5r S r g ) 9ManagedkafkaProjectsLocationsConnectClustersCreateRequestiaA ManagedkafkaProjectsLocationsConnectClustersCreateRequest object. Fields: connectCluster: A ConnectCluster resource to be passed as the request body. connectClusterId: Required. The ID to use for the Connect cluster, which will become the final component of the cluster's name. The ID must be 1-63 characters long, and match the regular expression `[a-z]([-a-z0-9]*[a-z0-9])?` to comply with RFC 1035. This value is structured like: `my-cluster-id`. parent: Required. The parent project/location in which to create the Kafka Connect cluster. Structured like `projects/{project}/locations/{location}/`. requestId: Optional. An optional request ID to identify requests. Specify a unique request ID to avoid duplication of requests. If a request times out or fails, retrying with the same ID allows the server to recognize the previous attempt. For at least 60 minutes, the server ignores duplicate requests bearing the same ID. For example, consider a situation where you make an initial request and the request times out. If you make the request again with the same request ID within 60 minutes of the last request, the server checks if an original operation with the same request ID was received. If so, the server ignores the second request. The request ID must be a valid UUID. A zero UUID is not supported (00000000-0000-0000-0000-000000000000). rr r r!TrPr"rN) rrrrrrrconnectClusterr&connectClusterIdrXrrrrrrrsO4))*:A>.**1-  T 2&##A&)rrc^\rSrSrSr\R "SSS9r\R "S5rSr g) 9ManagedkafkaProjectsLocationsConnectClustersDeleteRequestiaA ManagedkafkaProjectsLocationsConnectClustersDeleteRequest object. Fields: name: Required. The name of the Kafka Connect cluster to delete. Structured like `projects/{project}/locations/{location}/connectClusters /{connect_cluster_id}`. requestId: Optional. An optional request ID to identify requests. Specify a unique request ID to avoid duplication of requests. If a request times out or fails, retrying with the same ID allows the server to recognize the previous attempt. For at least 60 minutes, the server ignores duplicate requests bearing the same ID. For example, consider a situation where you make an initial request and the request times out. If you make the request again with the same request ID within 60 minutes of the last request, the server checks if an original operation with the same request ID was received. If so, the server ignores the second request. The request ID must be a valid UUID. A zero UUID is not supported (00000000-0000-0000-0000-000000000000). r TrPr rNrrrrrrs+&   q4 0$##A&)rrc:\rSrSrSr\R "SSS9rSrg)6ManagedkafkaProjectsLocationsConnectClustersGetRequesti*a A ManagedkafkaProjectsLocationsConnectClustersGetRequest object. Fields: name: Required. The name of the Kafka Connect cluster whose configuration to return. Structured like `projects/{project}/locations/{location}/conn ectClusters/{connect_cluster_id}`. r TrPrNr[rrrrr*rnrrc\rSrSrSr\R "S5r\R "S5r\R"S\RRS9r \R "S5r \R "SS S 9rS rg ) 7ManagedkafkaProjectsLocationsConnectClustersListRequesti6aA ManagedkafkaProjectsLocationsConnectClustersListRequest object. Fields: filter: Optional. Filter expression for the result. orderBy: Optional. Order by fields for the result. pageSize: Optional. The maximum number of Connect clusters to return. The service may return fewer than this value. If unspecified, server will pick an appropriate default. pageToken: Optional. A page token, received from a previous `ListConnectClusters` call. Provide this to retrieve the subsequent page. When paginating, all other parameters provided to `ListConnectClusters` must match the call that provided the page token. parent: Required. The parent project/location whose Connect clusters are to be listed. Structured like `projects/{project}/locations/{location}`. r r r!rr"r#TrPrNrrrrrr6rrrc\rSrSrSr\R "SS5r\R"SSS9r \R"S5r \R"S 5r S r g ) 8ManagedkafkaProjectsLocationsConnectClustersPatchRequestiNaA ManagedkafkaProjectsLocationsConnectClustersPatchRequest object. Fields: connectCluster: A ConnectCluster resource to be passed as the request body. name: Identifier. The name of the Kafka Connect cluster. Structured like: projects/{project_number}/locations/{location}/connectClusters/{connect_ cluster_id} requestId: Optional. An optional request ID to identify requests. Specify a unique request ID to avoid duplication of requests. If a request times out or fails, retrying with the same ID allows the server to recognize the previous attempt. For at least 60 minutes, the server ignores duplicate requests bearing the same ID. For example, consider a situation where you make an initial request and the request times out. If you make the request again with the same request ID within 60 minutes of the last request, the server checks if an original operation with the same request ID was received. If so, the server ignores the second request. The request ID must be a valid UUID. A zero UUID is not supported (00000000-0000-0000-0000-000000000000). updateMask: Required. Field mask is used to specify the fields to be overwritten in the cluster resource by the update. The fields specified in the update_mask are relative to the resource, not the full request. A field will be overwritten if it is in the mask. The mask is required and a value of * will update all fields. rr r TrPr!r"rN) rrrrrrrrr&r(rrgrrrrrrNsN4))*:A>.   q4 0$##A&)$$Q'*rrc:\rSrSrSr\R "SSS9rSrg)'ManagedkafkaProjectsLocationsGetRequestiozcA ManagedkafkaProjectsLocationsGetRequest object. Fields: name: Resource name for the location. r TrPrNr[rrrrro   q4 0$rrc\rSrSrSr\R "SSS9r\R "S5r\R "SSS9r \R"S \RRS 9r \R "S 5rS rg )(ManagedkafkaProjectsLocationsListRequestiyaA ManagedkafkaProjectsLocationsListRequest object. Fields: extraLocationTypes: Optional. Do not use this field. It is unsupported and is ignored unless explicitly documented otherwise. This is primarily for internal usage. filter: A filter to narrow down results to a preferred subset. The filtering language accepts strings like `"displayName=tokyo"`, and is documented in more detail in [AIP-160](https://google.aip.dev/160). name: The resource that owns the locations collection, if applicable. pageSize: The maximum number of results to return. If not set, the service selects a default. pageToken: A page token received from the `next_page_token` field in the response. Send that page token to receive the subsequent page. r Tr r r!rPr"rr#rN)rrrrrrr&extraLocationTypesrwr(r;rrrbrcrrrrrrysl !,,Q>   #&   q4 0$  # #Ay/@/@/F/F G(##A&)rrc`\rSrSrSr\R "SS5r\R"SSS9r Sr g ) 4ManagedkafkaProjectsLocationsOperationsCancelRequestizA ManagedkafkaProjectsLocationsOperationsCancelRequest object. Fields: cancelOperationRequest: A CancelOperationRequest resource to be passed as the request body. name: The name of the operation resource to be cancelled. rDr r TrPrN) rrrrrrrcancelOperationRequestr&r(rrrrrrs/%112JAN   q4 0$rrc:\rSrSrSr\R "SSS9rSrg)4ManagedkafkaProjectsLocationsOperationsDeleteRequestizA ManagedkafkaProjectsLocationsOperationsDeleteRequest object. Fields: name: The name of the operation resource to be deleted. r TrPrNr[rrrrrrrrc:\rSrSrSr\R "SSS9rSrg)1ManagedkafkaProjectsLocationsOperationsGetRequestizqA ManagedkafkaProjectsLocationsOperationsGetRequest object. Fields: name: The name of the operation resource. r TrPrNr[rrrrrrrrc\rSrSrSr\R "S5r\R "SSS9r\R"S\RRS9r \R "S 5r \R"S 5rS rg ) 2ManagedkafkaProjectsLocationsOperationsListRequestiaA ManagedkafkaProjectsLocationsOperationsListRequest object. Fields: filter: The standard list filter. name: The name of the operation's parent resource. pageSize: The standard list page size. pageToken: The standard list page token. returnPartialSuccess: When set to `true`, operations that are reachable are returned as normal, and those that are unreachable are returned in the [ListOperationsResponse.unreachable] field. This can only be `true` when reading across collections e.g. when `parent` is set to `"projects/example/locations/-"`. This field is not by default supported and will result in an `UNIMPLEMENTED` error if set unless explicitly documented otherwise in service or product specific documentation. r r TrPr!rr"r#rN)rrrrrrr&rwr(r;rrrbrcr6returnPartialSuccessrrrrrrsj   #&   q4 0$  # #Ay/@/@/F/F G(##A&)"//2rrc`\rSrSrSr\R "SS5r\R"SSS9r Sr g ) SManagedkafkaProjectsLocationsSchemaRegistriesCompatibilityCheckCompatibilityRequestiaA ManagedkafkaProjectsLocationsSchemaRegistriesCompatibilityCheckCompati bilityRequest object. Fields: checkCompatibilityRequest: A CheckCompatibilityRequest resource to be passed as the request body. name: Required. The name of the resource to check compatibility for. The format is either of following: * projects/{project}/locations/{location} /schemaRegistries/{schema_registry}/compatibility/subjects/*/versions: Check compatibility with one or more versions of the specified subject. * projects/{project}/locations/{location}/schemaRegistries/{schema_regis try}/compatibility/subjects/{subject}/versions/{version}: Check compatibility with a specific version of the subject. rQr r TrPrN rrrrrrrcheckCompatibilityRequestr&r(rrrrrr0 (445PRST   q4 0$rrc:\rSrSrSr\R "SSS9rSrg)@ManagedkafkaProjectsLocationsSchemaRegistriesConfigDeleteRequestiaA ManagedkafkaProjectsLocationsSchemaRegistriesConfigDeleteRequest object. Fields: name: Required. The resource name of subject to delete the config for. The format is * projects/{project}/locations/{location}/schemaRegistries/{sc hema_registry}/config/{subject} r TrPrNr[rrrrrr\rrc^\rSrSrSr\R "S5r\R"SSS9r Sr g) =ManagedkafkaProjectsLocationsSchemaRegistriesConfigGetRequestia<A ManagedkafkaProjectsLocationsSchemaRegistriesConfigGetRequest object. Fields: defaultToGlobal: Optional. If true, the config will fall back to the config at the global level if no subject level config is found. name: Required. The resource name to get the config for. It can be either of following: * projects/{project}/locations/{location}/schemaRegistries /{schema_registry}/config: Get config at global level. * projects/{proje ct}/locations/{location}/schemaRegistries/{schema_registry}/config/{subj ect}: Get config for a specific subject. r r TrPrN rrrrrrr6defaultToGlobalr&r(rrrrrrs+ **1-/   q4 0$rrc`\rSrSrSr\R "SSS9r\R"SS5r Sr g ) @ManagedkafkaProjectsLocationsSchemaRegistriesConfigUpdateRequestia%A ManagedkafkaProjectsLocationsSchemaRegistriesConfigUpdateRequest object. Fields: name: Required. The resource name to update the config for. It can be either of following: * projects/{project}/locations/{location}/schemaReg istries/{schema_registry}/config: Update config at global level. * proje cts/{project}/locations/{location}/schemaRegistries/{schema_registry}/co nfig/{subject}: Update config for a specific subject. updateSchemaConfigRequest: A UpdateSchemaConfigRequest resource to be passed as the request body. r TrPUpdateSchemaConfigRequestr rN rrrrrrr&r(rupdateSchemaConfigRequestrrrrrrs0    q4 0$'445PRSTrrc`\rSrSrSr\R "SS5r\R"SSS9r Sr g ) [ManagedkafkaProjectsLocationsSchemaRegistriesContextsCompatibilityCheckCompatibilityRequestiaA ManagedkafkaProjectsLocationsSchemaRegistriesContextsCompatibilityChec kCompatibilityRequest object. Fields: checkCompatibilityRequest: A CheckCompatibilityRequest resource to be passed as the request body. name: Required. The name of the resource to check compatibility for. The format is either of following: * projects/{project}/locations/{location} /schemaRegistries/{schema_registry}/compatibility/subjects/*/versions: Check compatibility with one or more versions of the specified subject. * projects/{project}/locations/{location}/schemaRegistries/{schema_regis try}/compatibility/subjects/{subject}/versions/{version}: Check compatibility with a specific version of the subject. rQr r TrPrNrrrrrrrrrc:\rSrSrSr\R "SSS9rSrg)HManagedkafkaProjectsLocationsSchemaRegistriesContextsConfigDeleteRequesti"aA ManagedkafkaProjectsLocationsSchemaRegistriesContextsConfigDeleteRequest object. Fields: name: Required. The resource name of subject to delete the config for. The format is * projects/{project}/locations/{location}/schemaRegistries/{sc hema_registry}/config/{subject} r TrPrNr[rrrrr"   q4 0$rrc^\rSrSrSr\R "S5r\R"SSS9r Sr g) EManagedkafkaProjectsLocationsSchemaRegistriesContextsConfigGetRequesti0aDA ManagedkafkaProjectsLocationsSchemaRegistriesContextsConfigGetRequest object. Fields: defaultToGlobal: Optional. If true, the config will fall back to the config at the global level if no subject level config is found. name: Required. The resource name to get the config for. It can be either of following: * projects/{project}/locations/{location}/schemaRegistries /{schema_registry}/config: Get config at global level. * projects/{proje ct}/locations/{location}/schemaRegistries/{schema_registry}/config/{subj ect}: Get config for a specific subject. r r TrPrNrrrrrr0s+ **1-/   q4 0$rrc`\rSrSrSr\R "SSS9r\R"SS5r Sr g ) HManagedkafkaProjectsLocationsSchemaRegistriesContextsConfigUpdateRequestiBa-A ManagedkafkaProjectsLocationsSchemaRegistriesContextsConfigUpdateRequest object. Fields: name: Required. The resource name to update the config for. It can be either of following: * projects/{project}/locations/{location}/schemaReg istries/{schema_registry}/config: Update config at global level. * proje cts/{project}/locations/{location}/schemaRegistries/{schema_registry}/co nfig/{subject}: Update config for a specific subject. updateSchemaConfigRequest: A UpdateSchemaConfigRequest resource to be passed as the request body. r TrPrr rNrrrrrrBs0    q4 0$'445PRSTrrc:\rSrSrSr\R "SSS9rSrg)?ManagedkafkaProjectsLocationsSchemaRegistriesContextsGetRequestiUaA ManagedkafkaProjectsLocationsSchemaRegistriesContextsGetRequest object. Fields: name: Required. The name of the context to return. Structured like: `proje cts/{project}/locations/{location}/schemaRegistries/{schema_registry}/co ntexts/{context}` r TrPrNr[rrrrrUr\rrc:\rSrSrSr\R "SSS9rSrg)@ManagedkafkaProjectsLocationsSchemaRegistriesContextsListRequestibzA ManagedkafkaProjectsLocationsSchemaRegistriesContextsListRequest object. Fields: parent: Required. The parent of the contexts. Structured like: `projects/{ project}/locations/{location}/schemaRegistries/{schema_registry}` r TrPrN rrrrrrr&rXrrrrrrbs  T 2&rrc:\rSrSrSr\R "SSS9rSrg)FManagedkafkaProjectsLocationsSchemaRegistriesContextsModeDeleteRequestinaA ManagedkafkaProjectsLocationsSchemaRegistriesContextsModeDeleteRequest object. Fields: name: Required. The resource name of subject to delete the mode for. The format is * projects/{project}/locations/{location}/schemaRegistries/{sc hema_registry}/mode/{subject} * projects/{project}/locations/{location}/ schemaRegistries/{schema_registry}/contexts/{context}/mode/{subject} r TrPrNr[rrrrrnrrrc:\rSrSrSr\R "SSS9rSrg)CManagedkafkaProjectsLocationsSchemaRegistriesContextsModeGetRequesti|aA ManagedkafkaProjectsLocationsSchemaRegistriesContextsModeGetRequest object. Fields: name: Required. The resource name of the mode. The format is * projects/{p roject}/locations/{location}/schemaRegistries/{schema_registry}/mode/{su bject}: mode for a schema registry, or * projects/{project}/locations/{l ocation}/schemaRegistries/{schema_registry}/contexts/{context}/mode/{sub ject}: mode for a specific subject in a specific context r TrPrNr[rrrrr|s    q4 0$rrc`\rSrSrSr\R "SSS9r\R"SS5r Sr g ) FManagedkafkaProjectsLocationsSchemaRegistriesContextsModeUpdateRequestia/A ManagedkafkaProjectsLocationsSchemaRegistriesContextsModeUpdateRequest object. Fields: name: Required. The resource name of the mode. The format is * projects/{p roject}/locations/{location}/schemaRegistries/{schema_registry}/mode/{su bject}: mode for a schema registry, or * projects/{project}/locations/{l ocation}/schemaRegistries/{schema_registry}/contexts/{context}/mode/{sub ject}: mode for a specific subject in a specific context updateSchemaModeRequest: A UpdateSchemaModeRequest resource to be passed as the request body. r TrPUpdateSchemaModeRequestr rN rrrrrrr&r(rupdateSchemaModeRequestrrrrrrs/    q4 0$%223LaPrrc^\rSrSrSr\R "SSS9r\R "S5rSr g) FManagedkafkaProjectsLocationsSchemaRegistriesContextsSchemasGetRequestiaA ManagedkafkaProjectsLocationsSchemaRegistriesContextsSchemasGetRequest object. Fields: name: Required. The name of the schema to return. Structured like: `projec ts/{project}/locations/{location}/schemaRegistries/{schema_registry}/sch emas/ids/{schema}` subject: Optional. Used to limit the search for the schema ID to a specific subject, otherwise the schema ID will be searched for in all subjects in the given specified context. r TrPr rN rrrrrrr&r(subjectrrrrrr+    q4 0$  ! !! $'rrc^\rSrSrSr\R "SSS9r\R "S5rSr g) LManagedkafkaProjectsLocationsSchemaRegistriesContextsSchemasGetSchemaRequestiaA ManagedkafkaProjectsLocationsSchemaRegistriesContextsSchemasGetSchemaRequest object. Fields: name: Required. The name of the schema to return. Structured like: `projec ts/{project}/locations/{location}/schemaRegistries/{schema_registry}/sch emas/ids/{schema}` subject: Optional. Used to limit the search for the schema ID to a specific subject, otherwise the schema ID will be searched for in all subjects in the given specified context. r TrPr rNrrrrrrs+    q4 0$  ! !! $'rrc\rSrSrSr\R "S5r\R"SSS9r \R"S5r Sr g ) OManagedkafkaProjectsLocationsSchemaRegistriesContextsSchemasSubjectsListRequestia[A ManagedkafkaProjectsLocationsSchemaRegistriesContextsSchemasSubjectsLi stRequest object. Fields: deleted: Optional. If true, the response will include soft-deleted subjects. The default is false. parent: Required. The schema resource whose associated subjects are to be listed. Structured like: `projects/{project}/locations/{location}/schema Registries/{schema_registry}/schemas/ids/{schema}` or `projects/{project }/locations/{location}/schemaRegistries/{schema_registry}/contexts/{cont ext}/schemas/ids/{schema}` subject: Optional. The subject to filter the subjects by. r r TrPr!rN rrrrrrr6rMr&rXrrrrrrrs;   " "1 %'  T 2&  ! !! $'rrc:\rSrSrSr\R "SSS9rSrg)LManagedkafkaProjectsLocationsSchemaRegistriesContextsSchemasTypesListRequestiaA ManagedkafkaProjectsLocationsSchemaRegistriesContextsSchemasTypesListRequest object. Fields: parent: Required. The parent schema registry whose schema types are to be listed. Structured like: `projects/{project}/locations/{location}/schema Registries/{schema_registry}` r TrPrNrrrrrrs  T 2&rrc\rSrSrSr\R "S5r\R"SSS9r \R"S5r Sr g ) OManagedkafkaProjectsLocationsSchemaRegistriesContextsSchemasVersionsListRequestiaA ManagedkafkaProjectsLocationsSchemaRegistriesContextsSchemasVersionsLi stRequest object. Fields: deleted: Optional. If true, the response will include soft-deleted versions of the schema, even if the subject is soft-deleted. The default is false. parent: Required. The schema whose schema versions are to be listed. Structured like: `projects/{project}/locations/{location}/schemaRegistri es/{schema_registry}/schemas/ids/{schema}` or `projects/{project}/locati ons/{location}/schemaRegistries/{schema_registry}/contexts/{context}/sch emas/ids/{schema}` subject: Optional. The subject to filter the subjects by. r r TrPr!rNrrrrr r ;   " "1 %'  T 2&  ! !! $'rr c^\rSrSrSr\R "SSS9r\R"S5r Sr g) JManagedkafkaProjectsLocationsSchemaRegistriesContextsSubjectsDeleteRequestia A ManagedkafkaProjectsLocationsSchemaRegistriesContextsSubjectsDeleteRequest object. Fields: name: Required. The name of the subject to delete. Structured like: `proje cts/{project}/locations/{location}/schemaRegistries/{schema_registry}/su bjects/{subject}` or `projects/{project}/locations/{location}/schemaRegi stries/{schema_registry}/contexts/{context}/subjects/{subject}` permanent: Optional. If true, the subject and all associated metadata including the schema ID will be deleted permanently. Otherwise, only the subject is soft-deleted. The default is false. Soft-deleted subjects can still be searched in ListSubjects API call with deleted=true query parameter. A soft-delete of a subject must be performed before a hard- delete. r TrPr rN rrrrrrr&r(r6 permanentrrrrr r +"   q4 0$$$Q')rr c\rSrSrSr\R "S5r\R"SSS9r \R"S5r Sr g ) HManagedkafkaProjectsLocationsSchemaRegistriesContextsSubjectsListRequesti aA ManagedkafkaProjectsLocationsSchemaRegistriesContextsSubjectsListRequest object. Fields: deleted: Optional. If true, the response will include soft-deleted subjects. The default is false. parent: Required. The parent schema registry/context whose subjects are to be listed. Structured like: `projects/{project}/locations/{location}/sch emaRegistries/{schema_registry}` or `projects/{project}/locations/{locat ion}/schemaRegistries/{schema_registry}/contexts/{context}` subjectPrefix: Optional. The context to filter the subjects by, in the format of `:.{context}:`. If unset, all subjects in the registry are returned. Set to empty string or add as '?subjectPrefix=' at the end of this request to list subjects in the default context. r r TrPr!rN rrrrrrr6rMr&rX subjectPrefixrrrrrr s;"  " "1 %'  T 2&''*-rrc`\rSrSrSr\R "SS5r\R"SSS9r Sr g ) QManagedkafkaProjectsLocationsSchemaRegistriesContextsSubjectsLookupVersionRequesti$ aA ManagedkafkaProjectsLocationsSchemaRegistriesContextsSubjectsLookupVer sionRequest object. Fields: lookupVersionRequest: A LookupVersionRequest resource to be passed as the request body. parent: Required. The subject to lookup the schema in. Structured like: `p rojects/{project}/locations/{location}/schemaRegistries/{schema_registry }/subjects/{subject}` or `projects/{project}/locations/{location}/schema Registries/{schema_registry}/contexts/{context}/subjects/{subject}` rJr r TrPrN rrrrrrrlookupVersionRequestr&rXrrrrrr$ / #//0FJ  T 2&rrc`\rSrSrSr\R "SS5r\R"SSS9r Sr g ) RManagedkafkaProjectsLocationsSchemaRegistriesContextsSubjectsVersionsCreateRequesti5 aA ManagedkafkaProjectsLocationsSchemaRegistriesContextsSubjectsVersionsC reateRequest object. Fields: createVersionRequest: A CreateVersionRequest resource to be passed as the request body. parent: Required. The subject to create the version for. Structured like: `projects/{project}/locations/{location}/schemaRegistries/{schema_regist ry}/subjects/{subject}` or `projects/{project}/locations/{location}/sche maRegistries/{schema_registry}/contexts/{context}/subjects/{subject}` rr r TrPrN rrrrrrrcreateVersionRequestr&rXrrrrrr5 rrrc^\rSrSrSr\R "SSS9r\R"S5r Sr g) RManagedkafkaProjectsLocationsSchemaRegistriesContextsSubjectsVersionsDeleteRequestiF aNA ManagedkafkaProjectsLocationsSchemaRegistriesContextsSubjectsVersionsD eleteRequest object. Fields: name: Required. The name of the subject version to delete. Structured like: `projects/{project}/locations/{location}/schemaRegistries/{schema_ registry}/subjects/{subject}/versions/{version}` or `projects/{project}/ locations/{location}/schemaRegistries/{schema_registry}/contexts/{contex t}/subjects/{subject}/versions/{version}` permanent: Optional. If true, both the version and the referenced schema ID will be permanently deleted. The default is false. If false, the version will be deleted but the schema ID will be retained. Soft-deleted versions can still be searched in ListVersions API call with deleted=true query parameter. A soft-delete of a version must be performed before a hard-delete. r TrPr rNrrrrrrF rrrc^\rSrSrSr\R "S5r\R"SSS9r Sr g) OManagedkafkaProjectsLocationsSchemaRegistriesContextsSubjectsVersionsGetRequesti\ aA ManagedkafkaProjectsLocationsSchemaRegistriesContextsSubjectsVersionsG etRequest object. Fields: deleted: Optional. If true, no matter if the subject/version is soft- deleted or not, it returns the version details. If false, it returns NOT_FOUND error if the subject/version is soft-deleted. The default is false. name: Required. The name of the subject to return versions. Structured like: `projects/{project}/locations/{location}/schemaRegistries/{schema_ registry}/subjects/{subject}/versions/{version}` or `projects/{project}/ locations/{location}/schemaRegistries/{schema_registry}/contexts/{contex t}/subjects/{subject}/versions/{version}` r r TrPrN rrrrrrr6rMr&r(rrrrr!r!\ +   " "1 %'   q4 0$rr!c^\rSrSrSr\R "S5r\R"SSS9r Sr g) UManagedkafkaProjectsLocationsSchemaRegistriesContextsSubjectsVersionsGetSchemaRequestip aA ManagedkafkaProjectsLocationsSchemaRegistriesContextsSubjectsVersionsG etSchemaRequest object. Fields: deleted: Optional. If true, no matter if the subject/version is soft- deleted or not, it returns the version details. If false, it returns NOT_FOUND error if the subject/version is soft-deleted. The default is false. name: Required. The name of the subject to return versions. Structured like: `projects/{project}/locations/{location}/schemaRegistries/{schema_ registry}/subjects/{subject}/versions/{version}` or `projects/{project}/ locations/{location}/schemaRegistries/{schema_registry}/contexts/{contex t}/subjects/{subject}/versions/{version}` r r TrPrNr"rrrr%r%p r#rr%c^\rSrSrSr\R "S5r\R"SSS9r Sr g) PManagedkafkaProjectsLocationsSchemaRegistriesContextsSubjectsVersionsListRequesti a.A ManagedkafkaProjectsLocationsSchemaRegistriesContextsSubjectsVersionsL istRequest object. Fields: deleted: Optional. If true, the response will include soft-deleted versions of an active or soft-deleted subject. The default is false. parent: Required. The subject whose versions are to be listed. Structured like: `projects/{project}/locations/{location}/schemaRegistries/{schema_ registry}/subjects/{subject}` or `projects/{project}/locations/{location }/schemaRegistries/{schema_registry}/contexts/{context}/subjects/{subjec t}` r r TrPrN rrrrrrr6rMr&rXrrrrr'r' s+   " "1 %'  T 2&rr'c:\rSrSrSr\R "SSS9rSrg)\ManagedkafkaProjectsLocationsSchemaRegistriesContextsSubjectsVersionsReferencedbyListRequesti aA ManagedkafkaProjectsLocationsSchemaRegistriesContextsSubjectsVersionsR eferencedbyListRequest object. Fields: parent: Required. The version to list referenced by. Structured like: `pro jects/{project}/locations/{location}/schemaRegistries/{schema_registry}/ subjects/{subject}/versions/{version}` or `projects/{project}/locations/ {location}/schemaRegistries/{schema_registry}/contexts/{context}/subject s/{subject}/versions/{version}` r TrPrNrrrrr*r*    T 2&rr*c`\rSrSrSr\R "SS5r\R"SSS9r Sr g ) :ManagedkafkaProjectsLocationsSchemaRegistriesCreateRequesti aIA ManagedkafkaProjectsLocationsSchemaRegistriesCreateRequest object. Fields: createSchemaRegistryRequest: A CreateSchemaRegistryRequest resource to be passed as the request body. parent: Required. The parent whose schema registry instance is to be created. Structured like: `projects/{project}/locations/{location}` rr r TrPrN) rrrrrrrcreateSchemaRegistryRequestr&rXrrrrr-r- s0!* 6 67TVW X  T 2&rr-c:\rSrSrSr\R "SSS9rSrg):ManagedkafkaProjectsLocationsSchemaRegistriesDeleteRequesti zA ManagedkafkaProjectsLocationsSchemaRegistriesDeleteRequest object. Fields: name: Required. The name of the schema registry instance to delete. Structured like: `projects/{project}/locations/{location}/schemaRegistri es/{schema_registry}` r TrPrNr[rrrr0r0 rnrr0c:\rSrSrSr\R "SSS9rSrg)7ManagedkafkaProjectsLocationsSchemaRegistriesGetRequesti zA ManagedkafkaProjectsLocationsSchemaRegistriesGetRequest object. Fields: name: Required. The name of the schema registry instance to return. Structured like: `projects/{project}/locations/{location}/schemaRegistri es/{schema_registry}` r TrPrNr[rrrr2r2 rnrr2c\rSrSrSr"SS\R 5r\R"SSS9r \R"SS5r S r g ) 8ManagedkafkaProjectsLocationsSchemaRegistriesListRequesti a+A ManagedkafkaProjectsLocationsSchemaRegistriesListRequest object. Enums: ViewValueValuesEnum: Optional. Specifies the view to return for the schema registry instances. If not specified, the default view is SCHEMA_REGISTRY_VIEW_BASIC. Fields: parent: Required. The parent whose schema registry instances are to be listed. Structured like: `projects/{project}/locations/{location}` view: Optional. Specifies the view to return for the schema registry instances. If not specified, the default view is SCHEMA_REGISTRY_VIEW_BASIC. c$\rSrSrSrSrSrSrSrg)LManagedkafkaProjectsLocationsSchemaRegistriesListRequest.ViewValueValuesEnumi a=Optional. Specifies the view to return for the schema registry instances. If not specified, the default view is SCHEMA_REGISTRY_VIEW_BASIC. Values: SCHEMA_REGISTRY_VIEW_UNSPECIFIED: The unset value. The API will default to SCHEMA_REGISTRY_VIEW_BASIC. SCHEMA_REGISTRY_VIEW_BASIC: If SchemaRegistryView is not specified, this is the default value. Returns only the name of the schema registry. The contexts associated with it are not included. SCHEMA_REGISTRY_VIEW_FULL: Returns the name of the schema registry and all the contexts associated with it. rr r rN) rrrrr SCHEMA_REGISTRY_VIEW_UNSPECIFIEDSCHEMA_REGISTRY_VIEW_BASICSCHEMA_REGISTRY_VIEW_FULLrrrrrvr6 s ()$!" !rrvr TrPr rN) rrrrrrr_rvr&rXrbrxrrrrr4r4 s> "INN"$  T 2&   2A 6$rr4c:\rSrSrSr\R "SSS9rSrg)>ManagedkafkaProjectsLocationsSchemaRegistriesModeDeleteRequesti aA ManagedkafkaProjectsLocationsSchemaRegistriesModeDeleteRequest object. Fields: name: Required. The resource name of subject to delete the mode for. The format is * projects/{project}/locations/{location}/schemaRegistries/{sc hema_registry}/mode/{subject} * projects/{project}/locations/{location}/ schemaRegistries/{schema_registry}/contexts/{context}/mode/{subject} r TrPrNr[rrrr;r; r\rr;c:\rSrSrSr\R "SSS9rSrg);ManagedkafkaProjectsLocationsSchemaRegistriesModeGetRequesti aA ManagedkafkaProjectsLocationsSchemaRegistriesModeGetRequest object. Fields: name: Required. The resource name of the mode. The format is * projects/{p roject}/locations/{location}/schemaRegistries/{schema_registry}/mode/{su bject}: mode for a schema registry, or * projects/{project}/locations/{l ocation}/schemaRegistries/{schema_registry}/contexts/{context}/mode/{sub ject}: mode for a specific subject in a specific context r TrPrNr[rrrr=r= rrr=c`\rSrSrSr\R "SSS9r\R"SS5r Sr g ) >ManagedkafkaProjectsLocationsSchemaRegistriesModeUpdateRequesti a'A ManagedkafkaProjectsLocationsSchemaRegistriesModeUpdateRequest object. Fields: name: Required. The resource name of the mode. The format is * projects/{p roject}/locations/{location}/schemaRegistries/{schema_registry}/mode/{su bject}: mode for a schema registry, or * projects/{project}/locations/{l ocation}/schemaRegistries/{schema_registry}/contexts/{context}/mode/{sub ject}: mode for a specific subject in a specific context updateSchemaModeRequest: A UpdateSchemaModeRequest resource to be passed as the request body. r TrPrr rNrrrrr?r? s/    q4 0$%223LaPrr?c^\rSrSrSr\R "SSS9r\R "S5rSr g) >ManagedkafkaProjectsLocationsSchemaRegistriesSchemasGetRequesti aA ManagedkafkaProjectsLocationsSchemaRegistriesSchemasGetRequest object. Fields: name: Required. The name of the schema to return. Structured like: `projec ts/{project}/locations/{location}/schemaRegistries/{schema_registry}/sch emas/ids/{schema}` subject: Optional. Used to limit the search for the schema ID to a specific subject, otherwise the schema ID will be searched for in all subjects in the given specified context. r TrPr rNrrrrrArA s+    q4 0$  ! !! $'rrAc^\rSrSrSr\R "SSS9r\R "S5rSr g) DManagedkafkaProjectsLocationsSchemaRegistriesSchemasGetSchemaRequesti- aA ManagedkafkaProjectsLocationsSchemaRegistriesSchemasGetSchemaRequest object. Fields: name: Required. The name of the schema to return. Structured like: `projec ts/{project}/locations/{location}/schemaRegistries/{schema_registry}/sch emas/ids/{schema}` subject: Optional. Used to limit the search for the schema ID to a specific subject, otherwise the schema ID will be searched for in all subjects in the given specified context. r TrPr rNrrrrrCrC- rrrCc\rSrSrSr\R "S5r\R"SSS9r \R"S5r Sr g ) GManagedkafkaProjectsLocationsSchemaRegistriesSchemasSubjectsListRequesti> aRA ManagedkafkaProjectsLocationsSchemaRegistriesSchemasSubjectsListRequest object. Fields: deleted: Optional. If true, the response will include soft-deleted subjects. The default is false. parent: Required. The schema resource whose associated subjects are to be listed. Structured like: `projects/{project}/locations/{location}/schema Registries/{schema_registry}/schemas/ids/{schema}` or `projects/{project }/locations/{location}/schemaRegistries/{schema_registry}/contexts/{cont ext}/schemas/ids/{schema}` subject: Optional. The subject to filter the subjects by. r r TrPr!rNrrrrrErE> r rrEc:\rSrSrSr\R "SSS9rSrg)DManagedkafkaProjectsLocationsSchemaRegistriesSchemasTypesListRequestiS aA ManagedkafkaProjectsLocationsSchemaRegistriesSchemasTypesListRequest object. Fields: parent: Required. The parent schema registry whose schema types are to be listed. Structured like: `projects/{project}/locations/{location}/schema Registries/{schema_registry}` r TrPrNrrrrrGrGS s  T 2&rrGc\rSrSrSr\R "S5r\R"SSS9r \R"S5r Sr g ) GManagedkafkaProjectsLocationsSchemaRegistriesSchemasVersionsListRequesti` a|A ManagedkafkaProjectsLocationsSchemaRegistriesSchemasVersionsListRequest object. Fields: deleted: Optional. If true, the response will include soft-deleted versions of the schema, even if the subject is soft-deleted. The default is false. parent: Required. The schema whose schema versions are to be listed. Structured like: `projects/{project}/locations/{location}/schemaRegistri es/{schema_registry}/schemas/ids/{schema}` or `projects/{project}/locati ons/{location}/schemaRegistries/{schema_registry}/contexts/{context}/sch emas/ids/{schema}` subject: Optional. The subject to filter the subjects by. r r TrPr!rNrrrrrIrI` s;  " "1 %'  T 2&  ! !! $'rrIc^\rSrSrSr\R "SSS9r\R"S5r Sr g) BManagedkafkaProjectsLocationsSchemaRegistriesSubjectsDeleteRequestiv aA ManagedkafkaProjectsLocationsSchemaRegistriesSubjectsDeleteRequest object. Fields: name: Required. The name of the subject to delete. Structured like: `proje cts/{project}/locations/{location}/schemaRegistries/{schema_registry}/su bjects/{subject}` or `projects/{project}/locations/{location}/schemaRegi stries/{schema_registry}/contexts/{context}/subjects/{subject}` permanent: Optional. If true, the subject and all associated metadata including the schema ID will be deleted permanently. Otherwise, only the subject is soft-deleted. The default is false. Soft-deleted subjects can still be searched in ListSubjects API call with deleted=true query parameter. A soft-delete of a subject must be performed before a hard- delete. r TrPr rNrrrrrKrKv s+   q4 0$$$Q')rrKc\rSrSrSr\R "S5r\R"SSS9r \R"S5r Sr g ) @ManagedkafkaProjectsLocationsSchemaRegistriesSubjectsListRequesti aA ManagedkafkaProjectsLocationsSchemaRegistriesSubjectsListRequest object. Fields: deleted: Optional. If true, the response will include soft-deleted subjects. The default is false. parent: Required. The parent schema registry/context whose subjects are to be listed. Structured like: `projects/{project}/locations/{location}/sch emaRegistries/{schema_registry}` or `projects/{project}/locations/{locat ion}/schemaRegistries/{schema_registry}/contexts/{context}` subjectPrefix: Optional. The context to filter the subjects by, in the format of `:.{context}:`. If unset, all subjects in the registry are returned. Set to empty string or add as '?subjectPrefix=' at the end of this request to list subjects in the default context. r r TrPr!rNrrrrrMrM s;  " "1 %'  T 2&''*-rrMc`\rSrSrSr\R "SS5r\R"SSS9r Sr g ) IManagedkafkaProjectsLocationsSchemaRegistriesSubjectsLookupVersionRequesti aA ManagedkafkaProjectsLocationsSchemaRegistriesSubjectsLookupVersionRequest object. Fields: lookupVersionRequest: A LookupVersionRequest resource to be passed as the request body. parent: Required. The subject to lookup the schema in. Structured like: `p rojects/{project}/locations/{location}/schemaRegistries/{schema_registry }/subjects/{subject}` or `projects/{project}/locations/{location}/schema Registries/{schema_registry}/contexts/{context}/subjects/{subject}` rJr r TrPrNrrrrrOrO / #//0FJ  T 2&rrOc`\rSrSrSr\R "SS5r\R"SSS9r Sr g ) JManagedkafkaProjectsLocationsSchemaRegistriesSubjectsVersionsCreateRequesti aA ManagedkafkaProjectsLocationsSchemaRegistriesSubjectsVersionsCreateRequest object. Fields: createVersionRequest: A CreateVersionRequest resource to be passed as the request body. parent: Required. The subject to create the version for. Structured like: `projects/{project}/locations/{location}/schemaRegistries/{schema_regist ry}/subjects/{subject}` or `projects/{project}/locations/{location}/sche maRegistries/{schema_registry}/contexts/{context}/subjects/{subject}` rr r TrPrNrrrrrRrR rPrrRc^\rSrSrSr\R "SSS9r\R"S5r Sr g) JManagedkafkaProjectsLocationsSchemaRegistriesSubjectsVersionsDeleteRequesti aEA ManagedkafkaProjectsLocationsSchemaRegistriesSubjectsVersionsDeleteRequest object. Fields: name: Required. The name of the subject version to delete. Structured like: `projects/{project}/locations/{location}/schemaRegistries/{schema_ registry}/subjects/{subject}/versions/{version}` or `projects/{project}/ locations/{location}/schemaRegistries/{schema_registry}/contexts/{contex t}/subjects/{subject}/versions/{version}` permanent: Optional. If true, both the version and the referenced schema ID will be permanently deleted. The default is false. If false, the version will be deleted but the schema ID will be retained. Soft-deleted versions can still be searched in ListVersions API call with deleted=true query parameter. A soft-delete of a version must be performed before a hard-delete. r TrPr rNrrrrrTrT s+$   q4 0$$$Q')rrTc^\rSrSrSr\R "S5r\R"SSS9r Sr g) GManagedkafkaProjectsLocationsSchemaRegistriesSubjectsVersionsGetRequesti aA ManagedkafkaProjectsLocationsSchemaRegistriesSubjectsVersionsGetRequest object. Fields: deleted: Optional. If true, no matter if the subject/version is soft- deleted or not, it returns the version details. If false, it returns NOT_FOUND error if the subject/version is soft-deleted. The default is false. name: Required. The name of the subject to return versions. Structured like: `projects/{project}/locations/{location}/schemaRegistries/{schema_ registry}/subjects/{subject}/versions/{version}` or `projects/{project}/ locations/{location}/schemaRegistries/{schema_registry}/contexts/{contex t}/subjects/{subject}/versions/{version}` r r TrPrNr"rrrrVrV s+  " "1 %'   q4 0$rrVc^\rSrSrSr\R "S5r\R"SSS9r Sr g) MManagedkafkaProjectsLocationsSchemaRegistriesSubjectsVersionsGetSchemaRequesti aA ManagedkafkaProjectsLocationsSchemaRegistriesSubjectsVersionsGetSchema Request object. Fields: deleted: Optional. If true, no matter if the subject/version is soft- deleted or not, it returns the version details. If false, it returns NOT_FOUND error if the subject/version is soft-deleted. The default is false. name: Required. The name of the subject to return versions. Structured like: `projects/{project}/locations/{location}/schemaRegistries/{schema_ registry}/subjects/{subject}/versions/{version}` or `projects/{project}/ locations/{location}/schemaRegistries/{schema_registry}/contexts/{contex t}/subjects/{subject}/versions/{version}` r r TrPrNr"rrrrXrX r#rrXc^\rSrSrSr\R "S5r\R"SSS9r Sr g) HManagedkafkaProjectsLocationsSchemaRegistriesSubjectsVersionsListRequesti a%A ManagedkafkaProjectsLocationsSchemaRegistriesSubjectsVersionsListRequest object. Fields: deleted: Optional. If true, the response will include soft-deleted versions of an active or soft-deleted subject. The default is false. parent: Required. The subject whose versions are to be listed. Structured like: `projects/{project}/locations/{location}/schemaRegistries/{schema_ registry}/subjects/{subject}` or `projects/{project}/locations/{location }/schemaRegistries/{schema_registry}/contexts/{context}/subjects/{subjec t}` r r TrPrNr(rrrrZrZ s+   " "1 %'  T 2&rrZc:\rSrSrSr\R "SSS9rSrg)TManagedkafkaProjectsLocationsSchemaRegistriesSubjectsVersionsReferencedbyListRequesti aA ManagedkafkaProjectsLocationsSchemaRegistriesSubjectsVersionsReference dbyListRequest object. Fields: parent: Required. The version to list referenced by. Structured like: `pro jects/{project}/locations/{location}/schemaRegistries/{schema_registry}/ subjects/{subject}/versions/{version}` or `projects/{project}/locations/ {location}/schemaRegistries/{schema_registry}/contexts/{context}/subject s/{subject}/versions/{version}` r TrPrNrrrrr\r\ r+rr\c<\rSrSrSr\R "S5rSrg)r i' aThe configuration of a Virtual Private Cloud (VPC) network that can access the Kafka cluster. Fields: subnet: Required. Name of the VPC subnet in which to create Private Service Connect (PSC) endpoints for the Kafka brokers and bootstrap address. Structured like: projects/{project}/regions/{region}/subnetworks/{subnet_id} The subnet must be located in the same region as the Kafka cluster. The project may differ. Multiple subnets from the same parent network must not be specified. r rN) rrrrrrr&subnetrrrrr r ' s    #&rr cz\rSrSrSr\R "S5"SS\R55r \R "S5"SS\R55r \R"S5r \R"S S 5r\R"SS 5r\R "S 5r\R"SS 5rSrg)r4i8 aThis resource represents a long-running operation that is the result of a network API call. Messages: MetadataValue: Service-specific metadata associated with the operation. It typically contains progress information and common metadata such as create time. Some services might not provide such metadata. Any method that returns a long-running operation should document the metadata type, if any. ResponseValue: The normal, successful response of the operation. If the original method returns no data on success, such as `Delete`, the response is `google.protobuf.Empty`. If the original method is standard `Get`/`Create`/`Update`, the response should be the resource. For other methods, the response should have the type `XxxResponse`, where `Xxx` is the original method name. For example, if the original method name is `TakeSnapshot()`, the inferred response type is `TakeSnapshotResponse`. Fields: done: If the value is `false`, it means the operation is still in progress. If `true`, the operation is completed, and either `error` or `response` is available. error: The error result of the operation in case of failure or cancellation. metadata: Service-specific metadata associated with the operation. It typically contains progress information and common metadata such as create time. Some services might not provide such metadata. Any method that returns a long-running operation should document the metadata type, if any. name: The server-assigned name, which is only unique within the same service that originally returns it. If you use the default HTTP mapping, the `name` should be a resource name ending with `operations/{unique_id}`. response: The normal, successful response of the operation. If the original method returns no data on success, such as `Delete`, the response is `google.protobuf.Empty`. If the original method is standard `Get`/`Create`/`Update`, the response should be the resource. For other methods, the response should have the type `XxxResponse`, where `Xxx` is the original method name. For example, if the original method name is `TakeSnapshot()`, the inferred response type is `TakeSnapshotResponse`. rscf\rSrSrSr"SS\R 5r\R"SSSS9r Sr g ) Operation.MetadataValueib aService-specific metadata associated with the operation. It typically contains progress information and common metadata such as create time. Some services might not provide such metadata. Any method that returns a long-running operation should document the metadata type, if any. Messages: AdditionalProperty: An additional property for a MetadataValue object. Fields: additionalProperties: Properties of the object. Contains field @type with type URL. cb\rSrSrSr\R "S5r\R"SS5r Sr g)*Operation.MetadataValue.AdditionalPropertyiq rEr rr rNrrrrr{rcq rrr{r Tr rNr}rrrrFrab s4  AY.. A%112FTXYrrFcf\rSrSrSr"SS\R 5r\R"SSSS9r Sr g ) Operation.ResponseValuei~ aThe normal, successful response of the operation. If the original method returns no data on success, such as `Delete`, the response is `google.protobuf.Empty`. If the original method is standard `Get`/`Create`/`Update`, the response should be the resource. For other methods, the response should have the type `XxxResponse`, where `Xxx` is the original method name. For example, if the original method name is `TakeSnapshot()`, the inferred response type is `TakeSnapshotResponse`. Messages: AdditionalProperty: An additional property for a ResponseValue object. Fields: additionalProperties: Properties of the object. Contains field @type with type URL. cb\rSrSrSr\R "S5r\R"SS5r Sr g)*Operation.ResponseValue.AdditionalPropertyi zAn additional property for a ResponseValue object. Fields: key: Name of the additional property. value: A extra_types.JsonValue attribute. r rr rNrrrrr{rg rrr{r Tr rNr}rrr ResponseValuere~ s4 AY.. A%112FTXYrrhr Statusr r!r"r#rN)rrrrrrrrr~rFrhr6donererrorrr&r(responserrrrr4r48 s'R !!"89Zi''Z:Z6 !!"89Zi''Z:Z<    "$  1 -%  # #OQ 7(   q !$  # #OQ 7(rr4c\rSrSrSr\R "S5r\R "S5r\R "S5r \R"S5r \R "S5r \R "S5r \R "S 5rS rg ) OperationMetadatai aRepresents the metadata of the long-running operation. Fields: apiVersion: Output only. API version used to start the operation. createTime: Output only. The time the operation was created. endTime: Output only. The time the operation finished running. requestedCancellation: Output only. Identifies whether the user has requested cancellation of the operation. Operations that have been cancelled successfully have Operation.error value with a google.rpc.Status.code of 1, corresponding to `Code.CANCELLED`. statusMessage: Output only. Human-readable status of the operation, if any. target: Output only. Server-defined resource path for the target of the operation. verb: Output only. Name of the verb executed by the operation. r r r!r"r#r$rrN)rrrrrrr& apiVersionrendTimer6requestedCancellation statusMessagetargetverbrrrrrnrn sz"$$Q'*$$Q'*  ! !! $'#003''*-   #&   q !$rrnc\rSrSrSrSrg)ri zRequest for PauseConnector.rNrFrrrrr $rrc\rSrSrSrSrg)PauseConnectorResponsei zResponse for PauseConnector.rNrFrrrrxrx %rrxch\rSrSrSr"SS\R 5r\R"SS5r Sr g)ri a-Defines rebalancing behavior of a Kafka cluster. Enums: ModeValueValuesEnum: Optional. The rebalance behavior for the cluster. When not specified, defaults to `NO_REBALANCE`. Fields: mode: Optional. The rebalance behavior for the cluster. When not specified, defaults to `NO_REBALANCE`. c$\rSrSrSrSrSrSrSrg)#RebalanceConfig.ModeValueValuesEnumi aMOptional. The rebalance behavior for the cluster. When not specified, defaults to `NO_REBALANCE`. Values: MODE_UNSPECIFIED: A mode was not specified. Do not use. NO_REBALANCE: Do not rebalance automatically. AUTO_REBALANCE_ON_SCALE_UP: Automatically rebalance topic partitions among brokers when the cluster is scaled up. rr r rN) rrrrrMODE_UNSPECIFIED NO_REBALANCEAUTO_REBALANCE_ON_SCALE_UPrrrrModeValueValuesEnumr| sL!"rrr rN rrrrrrr_rrbmoderrrrrr s,  #INN #   2A 6$rrcb\rSrSrSr\R "SS5r\R"S5r Sr g)RemoveAclEntryResponsei aResponse for RemoveAclEntry. Fields: acl: The updated acl. Returned if the removed acl entry was not the last entry in the acl. aclDeleted: Returned with value true if the removed acl entry was the last entry in the acl, resulting in acl deletion. rr r rN) rrrrrrrr5r6 aclDeletedrrrrrr s+ ua(#%%a(*rrc\rSrSrSrSrg)ri zRequest for RestartConnector.rNrFrrrrr &rrc\rSrSrSrSrg)RestartConnectorResponsei zResponse for RestartConnector.rNrFrrrrr s'rrc\rSrSrSrSrg)ri zRequest for ResumeConnector.rNrFrrrrr ryrrc\rSrSrSrSrg)ResumeConnectorResponsei zResponse for ResumeConnector.rNrFrrrrr rrrc\rSrSrSr"SS\R 5r\R"SSSS9r \R"S 5r \R"SS 5r S rg ) Schemai a Schema for a Kafka message. Enums: SchemaTypeValueValuesEnum: Optional. The schema type of the schema. Fields: references: Optional. The schema references used by the schema. schema: The schema payload. schemaType: Optional. The schema type of the schema. c(\rSrSrSrSrSrSrSrSr g) Schema.SchemaTypeValueValuesEnumi rVrr r r!rNrWrrrr\r r]rr\r^r Tr r r!rN)rrrrrrr_r\rr`r&rarbrcrrrrrr sQ  ).. %%&7TJ*   #&""#>B*rrc\rSrSrSr"SS\R 5r\R"S5r \R"SS5r \R"S5r Srg ) SchemaConfigi! aSchemaConfig represents configuration for a schema registry or a specific subject. Enums: CompatibilityValueValuesEnum: Required. The compatibility type of the schema. The default value is BACKWARD. If unset in a SchemaSubject-level SchemaConfig, defaults to the global value. If unset in a SchemaRegistry-level SchemaConfig, reverts to the default value. Fields: alias: Optional. The subject to which this subject is an alias of. Only applicable for subject config. compatibility: Required. The compatibility type of the schema. The default value is BACKWARD. If unset in a SchemaSubject-level SchemaConfig, defaults to the global value. If unset in a SchemaRegistry-level SchemaConfig, reverts to the default value. normalize: Optional. If true, the schema will be normalized before being stored or looked up. The default is false. If unset in a SchemaSubject- level SchemaConfig, the global value will be used. If unset in a SchemaRegistry-level SchemaConfig, reverts to the default value. c4\rSrSrSrSrSrSrSrSr Sr S r S r g ) )SchemaConfig.CompatibilityValueValuesEnumi8 aRequired. The compatibility type of the schema. The default value is BACKWARD. If unset in a SchemaSubject-level SchemaConfig, defaults to the global value. If unset in a SchemaRegistry-level SchemaConfig, reverts to the default value. Values: NONE: No compatibility check. BACKWARD: Backwards compatible with the most recent version. BACKWARD_TRANSITIVE: Backwards compatible with all previous versions. FORWARD: Forwards compatible with the most recent version. FORWARD_TRANSITIVE: Forwards compatible with all previous versions. FULL: Backwards and forwards compatible with the most recent version. FULL_TRANSITIVE: Backwards and forwards compatible with all previous versions. rr r r!r"r#r$rN rrrrrNONEBACKWARDBACKWARD_TRANSITIVEFORWARDFORWARD_TRANSITIVEFULLFULL_TRANSITIVErrrrCompatibilityValueValuesEnumr8 s. DHG DOrrr r r!rN)rrrrrrr_rr&aliasrb compatibilityr6rrrrrrr! sL,Y^^0    "%%%&DaH-$$Q')rrch\rSrSrSr"SS\R 5r\R"SS5r Sr g) SchemaModeiU aSchemaMode represents the mode of a schema registry or a specific subject. Four modes are supported: * NONE: deprecated. This was the default mode for a subject, but now the default is unset (which means use the global schema registry setting) * READONLY: The schema registry is in read-only mode. * READWRITE: The schema registry is in read-write mode, which allows limited write operations on the schema. * IMPORT: The schema registry is in import mode, which allows more editing operations on the schema for data importing purposes. Enums: ModeValueValuesEnum: Required. The mode type of a schema registry (READWRITE by default) or of a subject (unset by default, which means use the global schema registry setting). Fields: mode: Required. The mode type of a schema registry (READWRITE by default) or of a subject (unset by default, which means use the global schema registry setting). c(\rSrSrSrSrSrSrSrSr g) SchemaMode.ModeValueValuesEnumij aRequired. The mode type of a schema registry (READWRITE by default) or of a subject (unset by default, which means use the global schema registry setting). Values: NONE: The default / unset value. The subject mode is NONE/unset by default, which means use the global schema registry mode. This should not be used for setting the mode. READONLY: READONLY mode. READWRITE: READWRITE mode. IMPORT: IMPORT mode. rr r r!rN rrrrrrREADONLY READWRITEIMPORTrrrrrrj s  DHI Frrr rNrrrrrrU s,(INN$   2A 6$rrc\rSrSrSr\R "S5r\R "S5r\R"S\RRS9r Sr g) r^i zSchemaReference is a reference to a schema. Fields: name: Required. The name of the reference. subject: Required. The subject of the reference. version: Required. The version of the reference. r r r!rrN)rrrrrrr&r(rr;rrrrrrrr^r^ sG   q !$  ! !! $'  " "1i.?.?.E.E F'rr^c^\rSrSrSr\R "SSS9r\R "S5rSr g) ri aSchemaRegistry is a schema registry instance. Fields: contexts: Output only. The contexts of the schema registry instance. name: Identifier. The name of the schema registry instance. Structured like: `projects/{project}/locations/{location}/schemaRegistries/{schema_ registry}` The instance name {schema_registry} can contain the following: * Up to 255 characters. * Letters (uppercase or lowercase), numbers, and underscores. r Tr r rN) rrrrrrr&contextsr(rrrrrr s+  " "1t 4(   q !$rrch\rSrSrSr"SS\R 5r\R"S\RRS9r \R"SSS S 9r \R"S 5r\R "SS 5r\R"S 5r\R"S\RRS9rSrg) SchemaVersioni aVersion of a schema. Enums: SchemaTypeValueValuesEnum: Optional. The schema type of the schema. Fields: id: Required. The schema ID. references: Optional. The schema references used by the schema. schema: Required. The schema payload. schemaType: Optional. The schema type of the schema. subject: Required. The subject of the version. version: Required. The version ID c(\rSrSrSrSrSrSrSrSr g) 'SchemaVersion.SchemaTypeValueValuesEnumi rVrr r r!rNrWrrrr\r r]rr\r rr^r Tr r!r"r#r$rN)rrrrrrr_r\r;rrrrr`r&rarbrcrrrrrrrr s  ).. a):):)@)@A"%%&7TJ*   #&""#>B*  ! !! $'  " "1i.?.?.E.E F'rrc\rSrSrSr"SS\R 5r"SS\R 5r\R"SS5r \R"S5r \R"SS S S 9r \R"S 5r\R"S 5r\R"S5r\R"S5r\R$"SSS 9r\R"S5r\R"S5r\R"S5r\R"S5rSrg)StandardQueryParametersi aQuery parameters accepted by all methods. Enums: FXgafvValueValuesEnum: V1 error format. AltValueValuesEnum: Data format for response. Fields: f__xgafv: V1 error format. access_token: OAuth access token. alt: Data format for response. callback: JSONP fields: Selector specifying which fields to include in a partial response. key: API key. Your API key identifies your project and provides you with API access, quota, and reports. Required unless you provide an OAuth 2.0 token. oauth_token: OAuth 2.0 token for the current user. prettyPrint: Returns response with indentations and line breaks. quotaUser: Available to use for quota purposes for server-side applications. Can be any arbitrary string assigned to a user, but should not exceed 40 characters. trace: A tracing token of the form "token:" to include in api requests. uploadType: Legacy upload protocol for media (e.g. "media", "multipart"). upload_protocol: Upload protocol for media (e.g. "raw", "multipart"). c$\rSrSrSrSrSrSrSrg)*StandardQueryParameters.AltValueValuesEnumi zData format for response. Values: json: Responses with Content-Type of application/json media: Media download with context-dependent Content-Type proto: Responses with Content-Type of application/x-protobuf rr r rN) rrrrrjsonmediaprotorrrrAltValueValuesEnumr s D E Errc \rSrSrSrSrSrSrg)-StandardQueryParameters.FXgafvValueValuesEnumi zFV1 error format. Values: _1: v1 error format _2: v2 error format rr rN)rrrrr_1_2rrrrFXgafvValueValuesEnumr s B Brrr r r!r)defaultr"r#r$rrTrrrrrN)rrrrrrr_rrrbf__xgafvr& access_tokenaltcallbackfieldsry oauth_tokenr6 prettyPrint quotaUsertrace uploadTypeupload_protocolrrrrrr s4 9>>  inn  !8! <(&&q),0!VD#  " "1 %(   #&a #%%a(+&&q$7+##A&)    #%$$R(*))"-/rrc\rSrSrSr\R "S5"SS\R55r \R"S\RRS9r \R"SSS S 9r\R "S 5rS rg )rii aThe `Status` type defines a logical error model that is suitable for different programming environments, including REST APIs and RPC APIs. It is used by [gRPC](https://github.com/grpc). Each `Status` message contains three pieces of data: error code, error message, and error details. You can find out more about this error model and how to work with it in the [API Design Guide](https://cloud.google.com/apis/design/errors). Messages: DetailsValueListEntry: A DetailsValueListEntry object. Fields: code: The status code, which should be an enum value of google.rpc.Code. details: A list of messages that carry the error details. There is a common set of message types for APIs to use. message: A developer-facing error message, which should be in English. Any user-facing error message should be localized and sent in the google.rpc.Status.details field, or localized by the client. rscf\rSrSrSr"SS\R 5r\R"SSSS9r Sr g ) Status.DetailsValueListEntryi zA DetailsValueListEntry object. Messages: AdditionalProperty: An additional property for a DetailsValueListEntry object. Fields: additionalProperties: Properties of the object. Contains field @type with type URL. cb\rSrSrSr\R "S5r\R"SS5r Sr g)/Status.DetailsValueListEntry.AdditionalPropertyi" zAn additional property for a DetailsValueListEntry object. Fields: key: Name of the additional property. value: A extra_types.JsonValue attribute. r rr rNrrrrr{r" rrr{r Tr rNr}rrrDetailsValueListEntryr rrrr rr Tr r!rN)rrrrrrrrr~rr;rrcoderdetailsr&messagerrrrriri s|& !!"89Zi//Z:Z2   9+<+<+B+B C$  " "#:A M'  ! !! $'rric\rSrSrSrSrg)ri4 zRequest for StopConnector.rNrFrrrrr4 s#rrc\rSrSrSrSrg)StopConnectorResponsei8 zResponse for StopConnector.rNrFrrrrr8 rvrrc\rSrSrSr\R "S5r\R "S5r\R"S5r Sr g)ri< aTask Retry Policy is implemented on a best-effort basis. The default policy retries tasks with a minimum_backoff of 60 seconds, and a maximum_backoff of 12 hours. You can disable the policy by setting the task_retry_disabled field to true. Retry delay will be exponential based on provided minimum and maximum backoffs. https://en.wikipedia.org/wiki/Exponential_backoff. Note that the delay between consecutive task restarts may not always precisely match the configured settings. This can happen when the ConnectCluster is in rebalancing state or if the ConnectCluster is unresponsive etc. The default values for minimum and maximum backoffs are 60 seconds and 12 hours respectively. Fields: maximumBackoff: Optional. The maximum amount of time to wait before retrying a failed task. This sets an upper bound for the backoff delay. minimumBackoff: Optional. The minimum amount of time to wait before retrying a failed task. This sets a lower bound for the backoff delay. taskRetryDisabled: Optional. If true, task retry is disabled. r r r!rN) rrrrrrr&maximumBackoffminimumBackoffr6taskRetryDisabledrrrrrr< s:(((+.((+.,,Q/rrcb\rSrSrSr\R "S5r\R"SS5r Sr g)riV aThe TLS configuration for the Kafka cluster. Fields: sslPrincipalMappingRules: Optional. A list of rules for mapping from SSL principal names to short names. These are applied in order by Kafka. Refer to the Apache Kafka documentation for `ssl.principal.mapping.rules` for the precise formatting details and syntax. Example: "RULE:^CN=(.*?),OU=ServiceUsers.*$/$1@example.com/,DEFAULT" This is a static Kafka broker configuration. Setting or modifying this field will trigger a rolling restart of the Kafka brokers to apply the change. An empty string means no rules are applied (Kafka default). trustConfig: Optional. The configuration of the broker truststore. If specified, clients can use mTLS for authentication. r TrustConfigr rN) rrrrrrr&sslPrincipalMappingRulesr trustConfigrrrrrrV s, '2215&&}a8+rrcJ\rSrSrSr\R "S5"SS\R55r \R"SS5r \R"S5r \R"S\RR S 9r\R"S \RR S 9rS rg ) r;ik afA Kafka topic in a given cluster. Messages: ConfigsValue: Optional. Configurations for the topic that are overridden from the cluster defaults. The key of the map is a Kafka topic property name, for example: `cleanup.policy`, `compression.type`. Fields: configs: Optional. Configurations for the topic that are overridden from the cluster defaults. The key of the map is a Kafka topic property name, for example: `cleanup.policy`, `compression.type`. name: Identifier. The name of the topic. The `topic` segment is used when connecting directly to the cluster. Structured like: projects/{project}/ locations/{location}/clusters/{cluster}/topics/{topic} partitionCount: Required. The number of partitions this topic has. The partition count can only be increased, not decreased. Please note that if partitions are increased for a topic that has a key, the partitioning logic or the ordering of the messages will be affected. replicationFactor: Required. Immutable. The number of replicas of each partition. A replication factor of 3 is recommended for high availability. rscf\rSrSrSr"SS\R 5r\R"SSSS9r Sr g ) Topic.ConfigsValuei a[Optional. Configurations for the topic that are overridden from the cluster defaults. The key of the map is a Kafka topic property name, for example: `cleanup.policy`, `compression.type`. Messages: AdditionalProperty: An additional property for a ConfigsValue object. Fields: additionalProperties: Additional properties of type ConfigsValue c`\rSrSrSr\R "S5r\R "S5rSr g)%Topic.ConfigsValue.AdditionalPropertyi rr r rNrxrrrr{r r|rr{r Tr rNr}rrrrr rrrr r r!rr"rN)rrrrrrrrr~rrrr&r(r;rrpartitionCountreplicationFactorrrrrr;r;k s. !!"89ZY&&Z:Z2  " ">1 5'   q !$))!Y5F5F5L5LM.,,Q 8I8I8O8OPrr;c<\rSrSrSr\R "SSSS9rSrg) ri zSources of CA certificates to install in the broker's truststore. Fields: casConfigs: Optional. Configuration for the Google Certificate Authority Service. Maximum 10. rMr Tr rN) rrrrrrr casConfigsrrrrrr s%%&I1W[\*rrc<\rSrSrSr\R "S5rSrg)ri aUpdateOptions specifies options that influence how a cluster update is applied. These options control the behavior of the update process, rather than defining the desired end-state of a cluster. Fields: allowBrokerDownscaleOnClusterUpscale: Optional. If true, allows an update operation that increases the total vCPU and/or memory allocation of the cluster to significantly decrease the per-broker vCPU and/or memory allocation. This can result in reduced performance and availability. By default, the update operation will fail if an upscale request results in a vCPU or memory allocation for the brokers that is smaller than 90% of the current broker size. r rN) rrrrrrr6$allowBrokerDownscaleOnClusterUpscalerrrrrr s *3)?)?)B&rrc\rSrSrSr"SS\R 5r\R"SS5r \R"S5r Sr g) ri aRequest for updating schema config. On a SchemaSubject-level SchemaConfig, an unset field will be removed from the SchemaConfig. Enums: CompatibilityValueValuesEnum: Required. The compatibility type of the schemas. Cannot be unset for a SchemaRegistry-level SchemaConfig. If unset on a SchemaSubject-level SchemaConfig, removes the compatibility field for the SchemaConfig. Fields: compatibility: Required. The compatibility type of the schemas. Cannot be unset for a SchemaRegistry-level SchemaConfig. If unset on a SchemaSubject-level SchemaConfig, removes the compatibility field for the SchemaConfig. normalize: Optional. If true, the schema will be normalized before being stored or looked up. The default is false. Cannot be unset for a SchemaRegistry-level SchemaConfig. If unset on a SchemaSubject-level SchemaConfig, removes the normalize field for the SchemaConfig. c4\rSrSrSrSrSrSrSrSr Sr S r S r g ) 6UpdateSchemaConfigRequest.CompatibilityValueValuesEnumi aRequired. The compatibility type of the schemas. Cannot be unset for a SchemaRegistry-level SchemaConfig. If unset on a SchemaSubject-level SchemaConfig, removes the compatibility field for the SchemaConfig. Values: NONE: No compatibility check. BACKWARD: Backwards compatible with the most recent version. BACKWARD_TRANSITIVE: Backwards compatible with all previous versions. FORWARD: Forwards compatible with the most recent version. FORWARD_TRANSITIVE: Forwards compatible with all previous versions. FULL: Backwards and forwards compatible with the most recent version. FULL_TRANSITIVE: Backwards and forwards compatible with all previous versions. rr r r!r"r#r$rNrrrrrr s.  DHG DOrrr r rN) rrrrrrr_rrbrr6rrrrrrr s<(Y^^.%%&DaH-$$Q')rrch\rSrSrSr"SS\R 5r\R"SS5r Sr g)ri zRequest for updating schema registry or subject mode. Enums: ModeValueValuesEnum: Required. The mode type. Fields: mode: Required. The mode type. c(\rSrSrSrSrSrSrSrSr g) +UpdateSchemaModeRequest.ModeValueValuesEnumi a&Required. The mode type. Values: NONE: The default / unset value. The subject mode is NONE/unset by default, which means use the global schema registry mode. This should not be used for setting the mode. READONLY: READONLY mode. READWRITE: READWRITE mode. IMPORT: IMPORT mode. rr r r!rNrrrrrr s  DHI Frrr rNrrrrrr s,INN   2A 6$rrrz$.xgafvr1r2N)r __future__rapitools.base.protorpcliterrapitools.base.pyrrpackager~r rrr3r9r>rDrHrMrQrfrjrrrrrrrrrrrr rrrrrr"r&r)r,r/r3r7r:r0rJrOrVrZr^r`rfrirkrmrprzr}rrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrr r rrrrr!r%r'r*r-r0r2r4r;r=r?rArCrErGrIrKrMrOrRrTrVrXrZr\r r4rnrrxrrrrrrrrrr^rrrrirrrrr;rrrrAddCustomJsonFieldMappingAddCustomJsonEnumMappingrrrrrs  '<%(  M9$$ M+*)  +*\'y  '4 ))++ ) )9,, ) "I%% "=Y..= (Y&& ( $ (9(9 $& 1 1&D 5!2!2 5[)i[)| T)++ To)Y&&o)d8y((8"+9,,+%y?P?P%$1y?P?P1 1IO>O((3)J[J[3* 1)J[J[ 1 1yGXGX 13 HYHY3,(IZIZ(* MIZIZ M Q9K\K\ Q O)J[J[ O K HYHY K ' @Q@Q'B' @Q@Q'0 1Y=N=N 13i>O>O30(y?P?P(B1i.?.?1'y/@/@'0 19;L;L 119;L;L11 8I8I139J9J301ZcZkZk1( 1yGXGX 11IDUDU1"UyGXGXU$1bkbsbs1( 1yO`O` 11IL]L]1$UyO`O`U& 1iFWFW 1 3yGXGX 3 1YM^M^ 1 1)J[J[ 1QYM^M^Q$%YM^M^%"%S\SdSd%$%V_VgVg%( 3S\SdSd 3%V_VgVg%*(QZQbQb(,+yO`O`+.3XaXiXi3"3YbYjYj3"(YbYjYj(,1V_VgVg1(1\e\m\m1(3W`WhWh3$ 3clctct 3 3ARAR 3 1ARAR 1 1i>O>O 1#7y?P?P#7L 1YEVEV 1 1)BSBS 1QYEVEVQ" %YEVEV % %9K\K\%"%iN_N_%* 39K\K\ 3%iN_N_%,(IZIZ(*+yGXGX+,3PYPaPa3$3QZQbQb3$(QZQbQb(.1iN_N_1*1T]TeTe1(3yO`O`3& 3[d[l[l 3$I%%$"i8 !!i8X" ))"6%I--%&Y..&7i''7: )Y.. )'i//'(y00(&Y..&'i//'CY  C>1(9$$1(h'7""'7T Gi'' G "Y&& " "GI%%"GJ<.i//<.~0%Y  0%f$9,,$%I--%0i''049 !!9*5QI  5Qp])##]CI%%C$-( 1 1-(`7i//7: ""Z4!!114>!!114>r