$dZddlmZddlmZddlmZddlmZdZ GddejZ Gd d ejZ Gd d ejZ Gd dejZGddejZGddejZGddejZGddejZGddejZGddejZGddejZGddejZGdd ejZGd!d"ejZGd#d$ejZGd%d&ejZGd'd(ejZGd)d*ejZGd+d,ejZGd-d.ejZGd/d0ejZGd1d2ejZ Gd3d4ejZ!Gd5d6ejZ"Gd7d8ejZ#Gd9d:ejZ$Gd;dejZ&Gd?d@ejZ'GdAdBejZ(GdCdDejZ)GdEdFejZ*GdGdHejZ+GdIdJejZ,GdKdLejZ-GdMdNejZ.GdOdPejZ/GdQdRejZ0GdSdTejZ1GdUdVejZ2GdWdXejZ3GdYdZejZ4Gd[d\ejZ5Gd]d^ejZ6Gd_d`ejZ7GdadbejZ8GdcddejZ9GdedfejZ:GdgdhejZ;GdidjejZ<GdkdlejZ=GdmdnejZ>GdodpejZ?GdqdrejZ@GdsdtejZAGdudvejZBGdwdxejZCGdydzejZDGd{d|ejZEGd}d~ejZFGddejZGGddejZHGddejZIGddejZJGddejZKGddejZLGddejZMGddejZNGddejZOGddejZPGddejZQGddejZRGddejZSGddejZTGddejZUGddejZVGddejZWGddejZXGddejZYGddejZZGddejZ[GddejZ\GddejZ]GddejZ^GddejZ_GddejZ`GddejZaGddejZbGddejZcGddejZdGddejZeGddejZfGddejZgGddejZhGdÄdejZiGdńdejZjGdDŽdejZkGdɄdejZlGd˄dejZmGd̈́dejZnGdτdejZoGdфdejZpGdӄdejZqGdՄdejZrGdׄdejZsGdلdejZtGdۄdejZuGd݄dejZvGd߄dejZwGddejZxGddejZyGddejZzGddejZ{GddejZ|GddejZ}GddejZ~GddejZGddejZGddejZGddejZGddejZGddejZGddejZGddejZGddejZGddejZGddejZGddejZGddejZGd d ejZGd d ejZGd dejZGddejZGddejZGddejZGddejZGddejZGddejZGddejZGddejZGdd ejZGd!d"ejZGd#d$ejZGd%d&ejZGd'd(ejZGd)d*ejZGd+d,ejZGd-d.ejZGd/d0ejZGd1d2ejZGd3d4ejZGd5d6ejZGd7d8ejZejHed9d:ejJejLd;d<ejJejLd=d>y?(@zdGenerated message classes for managedkafka version v1. Manage Apache Kafka clusters and resources. )absolute_import)messages)encoding) extra_types managedkafkac:eZdZdZej dddZy) 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____doc__ _messages MessageFieldnetworkConfigsUlib/googlecloudsdk/generated_clients/apis/managedkafka/v1/managedkafka_v1_messages.pyr r s*9))/1tL.rr ceZdZdZej dddZejdZejdZ ejdZ ejd Z ejd Z y ) AclaRepresents 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 N) rrrrrr aclEntries StringFieldetagname patternType resourceName resourceTyperrrrrsz#J&y%%j!dC*   q !$   q !$% %%a(+&&&q),&&&q),rrceZdZdZej dZej dZej dZej dZ y)raRepresents 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 rrrN) rrrrrr"host operationpermissionType principalrrrrrKsQ&   q !$#i##A&)(9((+.#i##A&)rrcZeZdZdZej ddZejdZy)AddAclEntryResponsezResponse for AddAclEntry. Fields: acl: The updated acl. aclCreated: Whether the acl was created as a result of adding the acl entry. rr rN) rrrrrracl BooleanField aclCreatedrrrr.r.es/  ua(#%y%%a(*rr.ceZdZdZy)CancelOperationRequestz3The request message for Operations.CancelOperation.Nrrrrrrrr3r3rsr>si  ).. &y%%&7TJ* 9  #&"y""#>B* "I " "1 %'rr>c\eZdZdZej dZejddZy)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 rTr N) rrrrrr0 is_compatibler"rrrrrQrQs/))((+- "Y " "1t 4(rrQceZdZdZGddej ZejdGddejZ ejdGddejZ ejdd Z ejd d Zejd Zejd dZejdZejddZejdZejddZej,dZej,dZej2ddZejddZejddZejdZy)ClusteraAn Apache Kafka cluster deployed in a location. Enums: StateValueValuesEnum: Output only. The current state of the cluster. Messages: BrokersPerZoneValue: Output only. Only populated when FULL view is requested. The number of brokers per zone. LabelsValue: Optional. Labels as key value pairs. Fields: 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. 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 eZdZdZdZdZdZdZy)Cluster.StateValueValuesEnumOutput 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 rrNrrrrSTATE_UNSPECIFIEDCREATINGACTIVEDELETINGrrrStateValueValuesEnumrVH FHrr]additionalPropertiescdeZdZdZGddej ZejdddZy)Cluster.BrokersPerZoneValuea&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 cXeZdZdZej dZejdZy).Cluster.BrokersPerZoneValue.AdditionalPropertyzAn additional property for a BrokersPerZoneValue object. Fields: key: Name of the additional property. value: A string attribute. r rN) rrrrrr"keyr7valuerrrAdditionalPropertyrcs-  "I ! !! $c$i$$Q'errfr Tr N rrrrrMessagerfrr_rrrBrokersPerZoneValueras4  (Y.. (29112FTXYrricdeZdZdZGddej ZejdddZy)Cluster.LabelsValueOptional. Labels as key value pairs. Messages: AdditionalProperty: An additional property for a LabelsValue object. Fields: additionalProperties: Additional properties of type LabelsValue cXeZdZdZej dZej dZy)&Cluster.LabelsValue.AdditionalPropertyAn additional property for a LabelsValue object. Fields: key: Name of the additional property. value: A string attribute. r rNrrrrrr"rdrerrrrfrn-  "I ! !! $c#i##A&errfr Tr Nrgrrr LabelsValuerk 4 'Y.. '29112FTXYrrrr r6rr GcpConfigrrr RebalanceConfig TlsConfig UpdateOptions N)rrrrrrJr]rMapUnrecognizedFieldsrhrirrrbrokersPerZonecapacityConfigr" createTime gcpConfig kafkaVersionlabelsr$rebalanceConfigr0 satisfiesPzi satisfiesPzsrMstate tlsConfig updateOptions updateTimerrrrTrTs@ Y^^ "8!!"89ZI--Z:Z2"8!!"89ZI%%Z:Z.*9))*?C.)9))*:A>.$y$$Q'*$i$$[!4)&&&q), !9 ! !- 3&   q !$*I**+. !9 ! !- 3&$y$$Q'*$i$$%7;)&&&q), !9 ! !- 3&   q !$'''*,'''*, )  4b 9%$y$$R(*rrc^eZdZdZej ddZejddZy)raConfiguration 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 rTr N) rrrrrr accessConfigr" secretPathsrrrrrs2 (''(=qA,% %%a$7+rrceZdZdZej ddZej ddZej dZy)ra*The 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 rrN) rrrrrr"additionalSubnetsdnsDomainNames primarySubnetrrrrrsD0,i++A=(9((T:.')''*-rrc$eZdZdZGddej ZejdGddejZ ejddZ ejdZejdd Zejd d Zy ) ConnectoraMA 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. c,eZdZdZdZdZdZdZdZdZ dZ y ) Connector.StateValueValuesEnumaOutput 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 rrrrr N) rrrrrY UNASSIGNEDRUNNINGPAUSEDFAILED RESTARTINGSTOPPEDrrrr]rs- JG F FJGrr]r_cdeZdZdZGddej ZejdddZy)Connector.ConfigsValueaVOptional. 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 cXeZdZdZej dZej dZy))Connector.ConfigsValue.AdditionalPropertyAn additional property for a ConfigsValue object. Fields: key: Name of the additional property. value: A string attribute. r rNrprrrrfrrqrrfr Tr Nrgrrr ConfigsValuerrrrr rrTaskRetryPolicyrN)rrrrrrJr]rrrhrrconfigsr"r$rMrtaskRestartPolicyrrrrrs*Y^^*"8!!"89ZY&&Z:Z2 #I " ">1 5'   q !$ )  4a 8%,i,,->BrrceZdZdZej dGddejZejdZ ejddZ y) ConsumerGroupaA 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} r_cdeZdZdZGddej ZejdddZy)ConsumerGroup.TopicsValueaOptional. 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 cZeZdZdZej dZejddZy),ConsumerGroup.TopicsValue.AdditionalPropertyzAn additional property for a TopicsValue object. Fields: key: Name of the additional property. value: A ConsumerTopicMetadata attribute. r ConsumerTopicMetadatarN rrrrrr"rdrrerrrrfrG0  "I ! !! $c$i$$%.*Y**1-rrcreZdZdZGddej ZejdejjZ ejdZ ejddd Zejd Zej"dd Zejd ejjZy)CreateVersionRequestaHRequest 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 eZdZdZdZdZdZdZy).CreateVersionRequest.SchemaTypeValueValuesEnuma"Optional. 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 rrNrBrrrrGrs  D DHrrGr variantrrIrTr rrr N)rrrrrrJrGr7VariantINT32idr0 normalizerrKr"rLrMrNversionrrrrrs0 ).. ya):):)@)@A"$i$$Q')%y%%&7TJ* 9  #&"y""#>B* "I " "1i.?.?.E.E F'rrc`eZdZdZej dej jZy)CreateVersionResponsez^Response for CreateVersion. Fields: id: The unique identifier of the schema created. r rN) rrrrrr7rrrrrrrrs) ya):):)@)@A"rrceZdZdZy)Emptya!A 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); } Nr4rrrrrsrrcZeZdZdZej ddZejdZy)rtaConfiguration 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 rN) rrrrrrrr"kmsKeyrrrrtrts/ ('':, 9  #&rrtceZdZdZej dGddejZejdZ ejdZ ejddd Zy ) HttpBodyaMessage 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. r_cdeZdZdZGddej ZejdddZy)!HttpBody.ExtensionsValueListEntryaA ExtensionsValueListEntry object. Messages: AdditionalProperty: An additional property for a ExtensionsValueListEntry object. Fields: additionalProperties: Properties of the object. Contains field @type with type URL. cZeZdZdZej dZejddZy)4HttpBody.ExtensionsValueListEntry.AdditionalPropertyzAn additional property for a ExtensionsValueListEntry object. Fields: key: Name of the additional property. value: A extra_types.JsonValue attribute. r extra_types.JsonValuerNrrrrrfr.rrrfr Tr NrgrrrExtensionsValueListEntryr!rrrr rrTr N)rrrrrrrrhrr" contentType BytesFielddatar extensionsrrrrrsv:"8!!"89Z!2!2Z:Z2& %%a(+   a $%y%%&@!dS*rrc^eZdZdZej dddZejdZy)ListAclsResponsea'Response 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 rN) rrrrrraclsr" nextPageTokenrrrrr@s1   q4 8$')''*-rrceZdZdZej dddZejdZejddZ y) ListClustersResponsea=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. rTr Tr rrN) rrrrrrclustersr"r unreachablerrrrrOsE$Y # #Iq4 @(')''*-% %%a$7+rrceZdZdZej dddZejdZejddZ y) ListConnectClustersResponseaSResponse 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 rrN) rrrrrrconnectClustersr"rrrrrrr_sF+I**+;QN/')''*-% %%a$7+rrc^eZdZdZej dddZejdZy)ListConnectorsResponsea Response 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 rN) rrrrrr connectorsr"rrrrrros1&y%%k1tD*')''*-rrc^eZdZdZej dddZejdZy)ListConsumerGroupsResponseaPResponse 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 rN) rrrrrrconsumerGroupsr"rrrrrr}s1*9))/1tL.')''*-rrc^eZdZdZej dddZejdZy)ListLocationsResponsezThe 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 rN) rrrrrr locationsr"rrrrr r s1%i$$ZTB)')''*-rr c^eZdZdZej dZejdddZy)ListOperationsResponsezThe 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. r OperationrTr N) rrrrrr"rr operationsrrrrrs1()''*-%y%%k1tD*rrc:eZdZdZej dddZy)ListSchemaRegistriesResponsezdRequest for ListSchemaRegistries. Fields: schemaRegistries: The schema registry instances. rr Tr N)rrrrrrschemaRegistriesrrrrrs! ,Y++,B*rr%c^eZdZdZej ddZejddZy);ManagedkafkaProjectsLocationsClustersAclsAddAclEntryRequestaA 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 TrequiredrrN rrrrrr"r/raclEntryrrrr*r*51   a$/# #Y # #J 2(rr*ceZdZdZej ddZejdZejddZ y) 6ManagedkafkaProjectsLocationsClustersAclsCreateRequestaA 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 rrTr+N) rrrrrrr/r"aclIdparentrrrr1r1EsC,  ua(# )   "% 9 T 2&rr1c8eZdZdZej ddZy)6ManagedkafkaProjectsLocationsClustersAclsDeleteRequesta}A 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 Tr+Nrrrrrr"r$rrrr5r5a   q4 0$rr5c8eZdZdZej ddZy)3ManagedkafkaProjectsLocationsClustersAclsGetRequestazA 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 Tr+Nr6rrrr9r9nr7rr9ceZdZdZej dej jZejdZ ejddZ y) 4ManagedkafkaProjectsLocationsClustersAclsListRequestaA 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 rrrTr+N rrrrrr7rrpageSizer" pageTokenr3rrrr;r;{O $Y # #Ay/@/@/F/F G(#i##A&) 9 T 2&rr;ceZdZdZej ddZejddZejdZ y) 5ManagedkafkaProjectsLocationsClustersAclsPatchRequestacA 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 rTr+rN) rrrrrrr/r"r$ updateMaskrrrrArAsC0  ua(#   q4 0$$y$$Q'*rrAc^eZdZdZej ddZejddZy)>ManagedkafkaProjectsLocationsClustersAclsRemoveAclEntryRequestaA 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 Tr+rrNr-rrrrDrDr/rrDc8eZdZdZej ddZy)@ManagedkafkaProjectsLocationsClustersConsumerGroupsDeleteRequestaA ManagedkafkaProjectsLocationsClustersConsumerGroupsDeleteRequest object. Fields: name: Required. The name of the consumer group to delete. `projects/{proje ct}/locations/{location}/clusters/{cluster}/consumerGroups/{consumerGrou p}`. r Tr+Nr6rrrrFrFr7rrFc8eZdZdZej ddZy)=ManagedkafkaProjectsLocationsClustersConsumerGroupsGetRequestaA 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 Tr+Nr6rrrrHrH   q4 0$rrHc eZdZdZGddej ZejdZejdejjZ ejdZ ejdd Zejdd Zy ) >ManagedkafkaProjectsLocationsClustersConsumerGroupsListRequestaYA 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. ceZdZdZdZdZdZy)RManagedkafkaProjectsLocationsClustersConsumerGroupsListRequest.ViewValueValuesEnumaOptional. 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 rN)rrrrCONSUMER_GROUP_VIEW_UNSPECIFIEDCONSUMER_GROUP_VIEW_BASICCONSUMER_GROUP_VIEW_FULLrrrViewValueValuesEnumrMs '(# ! rrQr rrrrTr+rN)rrrrrrJrQr"filterr7rrr=r>r3rMviewrrrrKrKs.!INN! !9  #& #Y # #Ay/@/@/F/F G(#i##A&) 9 T 2&   2A 6$rrKceZdZdZej ddZejddZejdZ y) ?ManagedkafkaProjectsLocationsClustersConsumerGroupsPatchRequestaA 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 rTr+rN) rrrrrr consumerGroupr"r$rBrrrrUrUsC ))((!<-   q4 0$$y$$Q'*rrUceZdZdZej ddZejdZejddZ ejdZ y ) 2ManagedkafkaProjectsLocationsClustersCreateRequestasA 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). rTr rrTr+rN) rrrrrrclusterr" clusterIdr3 requestIdrrrrXrXsU. #I " "9a 0'#i##A&) 9 T 2&#i##A&)rrXc\eZdZdZej ddZej dZy)2ManagedkafkaProjectsLocationsClustersDeleteRequestaA 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 Tr+rNrrrrrr"r$r[rrrr]r]:s/"   q4 0$#i##A&)rr]ceZdZdZGddej ZejddZejddZ y) /ManagedkafkaProjectsLocationsClustersGetRequestaA 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. ceZdZdZdZdZdZy)CManagedkafkaProjectsLocationsClustersGetRequest.ViewValueValuesEnumaOptional. 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 rN)rrrrCLUSTER_VIEW_UNSPECIFIEDCLUSTER_VIEW_BASICCLUSTER_VIEW_FULLrrrrQrb]s  !rrQr Tr+rN) rrrrrrJrQr"r$rMrSrrrr`r`PsB INN   q4 0$   2A 6$rr`ceZdZdZej dZej dZejdejjZ ej dZ ej dd Z y ) 0ManagedkafkaProjectsLocationsClustersListRequestaA 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 rrrrrTr+Nrrrrrr"rRorderByr7rrr=r>r3rrrrgrgqs !9  #& !I ! !! $' #Y # #Ay/@/@/F/F G(#i##A&) 9 T 2&rrgceZdZdZej ddZejddZejdZ ejdZ y ) 1ManagedkafkaProjectsLocationsClustersPatchRequestaA 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. rTr rTr+rrN) rrrrrrrYr"r$r[rBrrrrlrlsU0 #I " "9a 0'   q4 0$#i##A&)$y$$Q'*rrlceZdZdZej ddZejddZej dZ y) 8ManagedkafkaProjectsLocationsClustersTopicsCreateRequestaA 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 Tr+rrrN) rrrrrr"r3rtopictopicIdrrrrnrnsC  !9 T 2& ) ! ,% !I ! !! $'rrnc8eZdZdZej ddZy)8ManagedkafkaProjectsLocationsClustersTopicsDeleteRequestzA ManagedkafkaProjectsLocationsClustersTopicsDeleteRequest object. Fields: name: Required. The name of the topic to delete. `projects/{project}/locat ions/{location}/clusters/{cluster}/topics/{topic}`. r Tr+Nr6rrrrrrrs   q4 0$rrrc8eZdZdZej ddZy)5ManagedkafkaProjectsLocationsClustersTopicsGetRequestzA 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 Tr+Nr6rrrrtrtrIrrtceZdZdZej dej jZejdZ ejddZ y) 6ManagedkafkaProjectsLocationsClustersTopicsListRequestaA 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 rrrTr+Nr<rrrrvrvr?rrvceZdZdZej ddZejddZej dZ y) 7ManagedkafkaProjectsLocationsClustersTopicsPatchRequestaA 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 Tr+rrrN) rrrrrr"r$rrorBrrrrxrxsC    q4 0$ ) ! ,%$y$$Q'*rrxceZdZdZej ddZejdZejddZ y) CManagedkafkaProjectsLocationsConnectClustersConnectorsCreateRequestaA 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 rrTr+N) rrrrrr connectorr" connectorIdr3rrrrzrzsC %i$$[!4)% %%a(+ 9 T 2&rrzc8eZdZdZej ddZy)CManagedkafkaProjectsLocationsConnectClustersConnectorsDeleteRequestaA 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 Tr+Nr6rrrr~r~r7rr~c8eZdZdZej ddZy)@ManagedkafkaProjectsLocationsConnectClustersConnectorsGetRequesta%A 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 Tr+Nr6rrrrrr7rrceZdZdZej dej jZejdZ ejddZ y) AManagedkafkaProjectsLocationsConnectClustersConnectorsListRequestaA 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 rrrTr+Nr<rrrrr)sO $Y # #Ay/@/@/F/F G(#i##A&) 9 T 2&rrceZdZdZej ddZejddZejdZ y) BManagedkafkaProjectsLocationsConnectClustersConnectorsPatchRequestaA 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 rTr+rN) rrrrrrr{r"r$rBrrrrr?sC %i$$[!4)   q4 0$$y$$Q'*rrc^eZdZdZej ddZejddZy)BManagedkafkaProjectsLocationsConnectClustersConnectorsPauseRequestawA 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 Tr+PauseConnectorRequestrN) rrrrrr"r$rpauseConnectorRequestrrrrrTs3    q4 0$0)001H!Lrrc^eZdZdZej ddZejddZy)DManagedkafkaProjectsLocationsConnectClustersConnectorsRestartRequestaA 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 Tr+RestartConnectorRequestrN) rrrrrr"r$rrestartConnectorRequestrrrrrds3    q4 0$2I223LaPrrc^eZdZdZej ddZejddZy)CManagedkafkaProjectsLocationsConnectClustersConnectorsResumeRequestazA 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 Tr+ResumeConnectorRequestrN) rrrrrr"r$rresumeConnectorRequestrrrrrts3    q4 0$19112JANrrc^eZdZdZej ddZejddZy)AManagedkafkaProjectsLocationsConnectClustersConnectorsStopRequestasA 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 Tr+StopConnectorRequestrN) rrrrrr"r$rstopConnectorRequestrrrrrs3    q4 0$///0FJrrceZdZdZej ddZejdZejddZ ejdZ y ) 9ManagedkafkaProjectsLocationsConnectClustersCreateRequestaA 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 rrTr+rN) rrrrrrconnectClusterr"connectClusterIdr3r[rrrrrsW4*9))*:A>.*Y**1- 9 T 2&#i##A&)rrc\eZdZdZej ddZej dZy)9ManagedkafkaProjectsLocationsConnectClustersDeleteRequesta.A 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 Tr+rNr^rrrrrs/&   q4 0$#i##A&)rrc8eZdZdZej ddZy)6ManagedkafkaProjectsLocationsConnectClustersGetRequestaA 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 Tr+Nr6rrrrrrIrrceZdZdZej dZej dZejdejjZ ej dZ ej dd Z y ) 7ManagedkafkaProjectsLocationsConnectClustersListRequesta-A 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 rrrrrTr+NrhrrrrrrjrrceZdZdZej ddZejddZejdZ ejdZ y ) 8ManagedkafkaProjectsLocationsConnectClustersPatchRequestaA 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 rTr+rrN) rrrrrrrr"r$r[rBrrrrrsV4*9))*:A>.   q4 0$#i##A&)$y$$Q'*rrc8eZdZdZej ddZy)'ManagedkafkaProjectsLocationsGetRequestziA ManagedkafkaProjectsLocationsGetRequest object. Fields: name: Resource name for the location. r Tr+Nr6rrrrr   q4 0$rrceZdZdZej ddZej dZej ddZejdejj Z ej d Z y ) (ManagedkafkaProjectsLocationsListRequestaA ManagedkafkaProjectsLocationsListRequest object. Fields: extraLocationTypes: Optional. Unless explicitly documented otherwise, don't use this unsupported field which is primarily intended 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 rrr+rrrN)rrrrrr"extraLocationTypesrRr$r7rrr=r>rrrrrsv -y,,Q> 9  #&   q4 0$ #Y # #Ay/@/@/F/F G(#i##A&)rrc^eZdZdZej ddZejddZy)4ManagedkafkaProjectsLocationsOperationsCancelRequestzA ManagedkafkaProjectsLocationsOperationsCancelRequest object. Fields: cancelOperationRequest: A CancelOperationRequest resource to be passed as the request body. name: The name of the operation resource to be cancelled. r3r rTr+N) rrrrrrcancelOperationRequestr"r$rrrrr4s329112JAN   q4 0$rrc8eZdZdZej ddZy)4ManagedkafkaProjectsLocationsOperationsDeleteRequestzA ManagedkafkaProjectsLocationsOperationsDeleteRequest object. Fields: name: The name of the operation resource to be deleted. r Tr+Nr6rrrrrArrrc8eZdZdZej ddZy)1ManagedkafkaProjectsLocationsOperationsGetRequestzwA ManagedkafkaProjectsLocationsOperationsGetRequest object. Fields: name: The name of the operation resource. r Tr+Nr6rrrrrKrrrceZdZdZej dZej ddZejdejjZ ej dZ y ) 2ManagedkafkaProjectsLocationsOperationsListRequestzA 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. r rTr+rrrN) rrrrrr"rRr$r7rrr=r>rrrrrUsa !9  #&   q4 0$ #Y # #Ay/@/@/F/F G(#i##A&)rrc^eZdZdZej ddZejddZy)SManagedkafkaProjectsLocationsSchemaRegistriesCompatibilityCheckCompatibilityRequestaA 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. r>r rTr+N rrrrrrcheckCompatibilityRequestr"r$rrrrre4 5i445PRST   q4 0$rrc8eZdZdZej ddZy)@ManagedkafkaProjectsLocationsSchemaRegistriesConfigDeleteRequestaA 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 Tr+Nr6rrrrryr7rrc\eZdZdZej dZejddZy)=ManagedkafkaProjectsLocationsSchemaRegistriesConfigGetRequestaNA 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 rTr+N rrrrrr0defaultToGlobalr"r$rrrrrs/ +I**1-/   q4 0$rrc^eZdZdZej ddZejddZy)@ManagedkafkaProjectsLocationsSchemaRegistriesConfigUpdateRequesta9A 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 Tr+UpdateSchemaConfigRequestrN rrrrrr"r$rupdateSchemaConfigRequestrrrrrs4    q4 0$4i445PRSTrrc^eZdZdZej ddZejddZy)[ManagedkafkaProjectsLocationsSchemaRegistriesContextsCompatibilityCheckCompatibilityRequestaA 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. r>r rTr+Nrrrrrrrrrc8eZdZdZej ddZy)HManagedkafkaProjectsLocationsSchemaRegistriesContextsConfigDeleteRequesta(A 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 Tr+Nr6rrrrr   q4 0$rrc\eZdZdZej dZejddZy)EManagedkafkaProjectsLocationsSchemaRegistriesContextsConfigGetRequestaXA 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 rTr+Nrrrrrrs/ +I**1-/   q4 0$rrc^eZdZdZej ddZejddZy)HManagedkafkaProjectsLocationsSchemaRegistriesContextsConfigUpdateRequestaCA 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 Tr+rrNrrrrrrs4    q4 0$4i445PRSTrrc8eZdZdZej ddZy)?ManagedkafkaProjectsLocationsSchemaRegistriesContextsGetRequestaA 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 Tr+Nr6rrrrrr7rrc8eZdZdZej ddZy)@ManagedkafkaProjectsLocationsSchemaRegistriesContextsListRequestzA ManagedkafkaProjectsLocationsSchemaRegistriesContextsListRequest object. Fields: parent: Required. The parent of the contexts. Structured like: `projects/{ project}/locations/{location}/schemaRegistries/{schema_registry}` r Tr+Nrrrrrr"r3rrrrrs !9 T 2&rrc8eZdZdZej ddZy)FManagedkafkaProjectsLocationsSchemaRegistriesContextsModeDeleteRequestaA 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 Tr+Nr6rrrrr rrrc8eZdZdZej ddZy)CManagedkafkaProjectsLocationsSchemaRegistriesContextsModeGetRequestaA 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 Tr+Nr6rrrrrs    q4 0$rrc^eZdZdZej ddZejddZy)FManagedkafkaProjectsLocationsSchemaRegistriesContextsModeUpdateRequestaCA 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 Tr+UpdateSchemaModeRequestrN rrrrrr"r$rupdateSchemaModeRequestrrrrr&s3    q4 0$2I223LaPrrc\eZdZdZej ddZej dZy)FManagedkafkaProjectsLocationsSchemaRegistriesContextsSchemasGetRequestaA 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 Tr+rNrrrrrr"r$subjectrrrrr8/    q4 0$ !I ! !! $'rrc\eZdZdZej ddZej dZy)LManagedkafkaProjectsLocationsSchemaRegistriesContextsSchemasGetSchemaRequestaA 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 Tr+rNrrrrrrIs/    q4 0$ !I ! !! $'rrceZdZdZej dZejddZejdZ y)OManagedkafkaProjectsLocationsSchemaRegistriesContextsSchemasSubjectsListRequestaqA 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 rTr+rN rrrrrr0r(r"r3rrrrrr[sA  #I " "1 %' 9 T 2& !I ! !! $'rrc8eZdZdZej ddZy)LManagedkafkaProjectsLocationsSchemaRegistriesContextsSchemasTypesListRequesta)A 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 Tr+Nrrrrrros !9 T 2&rrceZdZdZej dZejddZejdZ y)OManagedkafkaProjectsLocationsSchemaRegistriesContextsSchemasVersionsListRequestaA 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 rTr+rNrrrrrr}A  #I " "1 %' 9 T 2& !I ! !! $'rrc\eZdZdZej ddZejdZy)JManagedkafkaProjectsLocationsSchemaRegistriesContextsSubjectsDeleteRequesta%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 Tr+rN rrrrrr"r$r0 permanentrrrrr/"   q4 0$$i$$Q')rrceZdZdZej dZejddZejdZ y)HManagedkafkaProjectsLocationsSchemaRegistriesContextsSubjectsListRequesta A 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 rTr+rN rrrrrr0r(r"r3 subjectPrefixrrrrrsA" #I " "1 %' 9 T 2&')''*-rrc^eZdZdZej ddZejddZy)QManagedkafkaProjectsLocationsSchemaRegistriesContextsSubjectsLookupVersionRequestaA 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}` r%r rTr+N rrrrrrlookupVersionRequestr"r3rrrrr3 0//0FJ 9 T 2&rrc^eZdZdZej ddZejddZy)RManagedkafkaProjectsLocationsSchemaRegistriesContextsSubjectsVersionsCreateRequestaA 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 rTr+N rrrrrrcreateVersionRequestr"r3rrrrrrrrc\eZdZdZej ddZejdZy)RManagedkafkaProjectsLocationsSchemaRegistriesContextsSubjectsVersionsDeleteRequestajA 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 Tr+rNrrrrrrrrrc\eZdZdZej dZejddZy)OManagedkafkaProjectsLocationsSchemaRegistriesContextsSubjectsVersionsGetRequestaA 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 rTr+N rrrrrr0r(r"r$rrrrr/  #I " "1 %'   q4 0$rrc\eZdZdZej dZejddZy)UManagedkafkaProjectsLocationsSchemaRegistriesContextsSubjectsVersionsGetSchemaRequestaA 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 rTr+Nrrrrrr rrrc\eZdZdZej dZejddZy)PManagedkafkaProjectsLocationsSchemaRegistriesContextsSubjectsVersionsListRequestaBA 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 rTr+N rrrrrr0r(r"r3rrrrr s/  #I " "1 %' 9 T 2&rrc8eZdZdZej ddZy)\ManagedkafkaProjectsLocationsSchemaRegistriesContextsSubjectsVersionsReferencedbyListRequestaA 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 Tr+Nrrrrrr1   !9 T 2&rrc^eZdZdZej ddZejddZy):ManagedkafkaProjectsLocationsSchemaRegistriesCreateRequestaUA 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 rTr+N) rrrrrrcreateSchemaRegistryRequestr"r3rrrrr@ s4!7 6 67TVW X 9 T 2&rrc8eZdZdZej ddZy):ManagedkafkaProjectsLocationsSchemaRegistriesDeleteRequestaA 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 Tr+Nr6rrrr r N rIrr c8eZdZdZej ddZy)7ManagedkafkaProjectsLocationsSchemaRegistriesGetRequestaA 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 Tr+Nr6rrrr r Z rIrr ceZdZdZGddej ZejddZejddZ y) 8ManagedkafkaProjectsLocationsSchemaRegistriesListRequestaAA 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. ceZdZdZdZdZdZy)LManagedkafkaProjectsLocationsSchemaRegistriesListRequest.ViewValueValuesEnumaiOptional. 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 rN)rrrr SCHEMA_REGISTRY_VIEW_UNSPECIFIEDSCHEMA_REGISTRY_VIEW_BASICSCHEMA_REGISTRY_VIEW_FULLrrrrQrv s ()$!" !rrQr Tr+rN) rrrrrrJrQr"r3rMrSrrrrrf sB "INN"$ !9 T 2&   2A 6$rrc8eZdZdZej ddZy)>ManagedkafkaProjectsLocationsSchemaRegistriesModeDeleteRequestaA 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 Tr+Nr6rrrrr r7rrc8eZdZdZej ddZy);ManagedkafkaProjectsLocationsSchemaRegistriesModeGetRequestaA 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 Tr+Nr6rrrrr rrrc^eZdZdZej ddZejddZy)>ManagedkafkaProjectsLocationsSchemaRegistriesModeUpdateRequesta9A 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 Tr+rrNrrrrrr s3    q4 0$2I223LaPrrc\eZdZdZej ddZej dZy)>ManagedkafkaProjectsLocationsSchemaRegistriesSchemasGetRequestaA 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 Tr+rNrrrrrr s/    q4 0$ !I ! !! $'rrc\eZdZdZej ddZej dZy)DManagedkafkaProjectsLocationsSchemaRegistriesSchemasGetSchemaRequestaA 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 Tr+rNrrrrrr rrrceZdZdZej dZejddZejdZ y)GManagedkafkaProjectsLocationsSchemaRegistriesSchemasSubjectsListRequestajA 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 rTr+rNrrrrrr rrrc8eZdZdZej ddZy)DManagedkafkaProjectsLocationsSchemaRegistriesSchemasTypesListRequestaA 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 Tr+Nrrrrr!r! s !9 T 2&rr!ceZdZdZej dZejddZejdZ y)GManagedkafkaProjectsLocationsSchemaRegistriesSchemasVersionsListRequestaA 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 rTr+rNrrrrr#r# sA #I " "1 %' 9 T 2& !I ! !! $'rr#c\eZdZdZej ddZejdZy)BManagedkafkaProjectsLocationsSchemaRegistriesSubjectsDeleteRequestaA 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 Tr+rNrrrrr%r% s/   q4 0$$i$$Q')rr%ceZdZdZej dZejddZejdZ y)@ManagedkafkaProjectsLocationsSchemaRegistriesSubjectsListRequestaA 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 rTr+rNrrrrr'r'& sA #I " "1 %' 9 T 2&')''*-rr'c^eZdZdZej ddZejddZy)IManagedkafkaProjectsLocationsSchemaRegistriesSubjectsLookupVersionRequestaA 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}` r%r rTr+Nrrrrr)r)< 3 0//0FJ 9 T 2&rr)c^eZdZdZej ddZejddZy)JManagedkafkaProjectsLocationsSchemaRegistriesSubjectsVersionsCreateRequestaA 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 rTr+Nrrrrr,r,N r*rr,c\eZdZdZej ddZejdZy)JManagedkafkaProjectsLocationsSchemaRegistriesSubjectsVersionsDeleteRequestacA 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 Tr+rNrrrrr.r.` s/$   q4 0$$i$$Q')rr.c\eZdZdZej dZejddZy)GManagedkafkaProjectsLocationsSchemaRegistriesSubjectsVersionsGetRequestaA 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 rTr+Nrrrrr0r0w s/ #I " "1 %'   q4 0$rr0c\eZdZdZej dZejddZy)MManagedkafkaProjectsLocationsSchemaRegistriesSubjectsVersionsGetSchemaRequestaA 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 rTr+Nrrrrr2r2 rrr2c\eZdZdZej dZejddZy)HManagedkafkaProjectsLocationsSchemaRegistriesSubjectsVersionsListRequesta;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 rTr+Nrrrrr4r4 s/  #I " "1 %' 9 T 2&rr4c8eZdZdZej ddZy)TManagedkafkaProjectsLocationsSchemaRegistriesSubjectsVersionsReferencedbyListRequestaA 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 Tr+Nrrrrr6r6 rrr6c4eZdZdZej dZy)r 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 N)rrrrrr"subnetrrrr r s  !9  #&rr creZdZdZej dGddejZej dGddejZ ejdZ ejdd Z ejdd Zejd Zejdd Zy )ra This 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`. r_cdeZdZdZGddej ZejdddZy)Operation.MetadataValueaService-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. cZeZdZdZej dZejddZy)*Operation.MetadataValue.AdditionalPropertyr r rrNrrrrrfr= rrrfr Tr Nrgrrrr!r; s6  AY.. A29112FTXYrr!cdeZdZdZGddej ZejdddZy)Operation.ResponseValueaThe 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. cZeZdZdZej dZejddZy)*Operation.ResponseValue.AdditionalPropertyzAn additional property for a ResponseValue object. Fields: key: Name of the additional property. value: A extra_types.JsonValue attribute. r rrNrrrrrfrA+ rrrfr Tr Nrgrrr ResponseValuer? s6 AY.. A29112FTXYrrBr StatusrrrrN)rrrrrrrrhr!rBr0donererrorrr"r$responserrrrr s'R"8!!"89Zi''Z:Z6"8!!"89Zi''Z:Z<    "$ ) 1 -% #Y # #OQ 7(   q !$ #Y # #OQ 7(rrc eZdZdZej dZej dZej dZejdZ ej dZ ej dZ ej dZ y ) OperationMetadataaRepresents 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 rrrrr ruN)rrrrrr" apiVersionrendTimer0requestedCancellation statusMessagetargetverbrrrrHrH? s"%y$$Q'*$y$$Q'* !I ! !! $'0)003')''*- 9  #&   q !$rrHceZdZdZy)rzRequest for PauseConnector.Nr4rrrrrZ $rrceZdZdZy)PauseConnectorResponsezResponse for PauseConnector.Nr4rrrrRrR^ %rrRc`eZdZdZGddej ZejddZy)rva;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`. ceZdZdZdZdZdZy)#RebalanceConfig.ModeValueValuesEnumaiOptional. 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 rN)rrrrMODE_UNSPECIFIED NO_REBALANCEAUTO_REBALANCE_ON_SCALE_UPrrrModeValueValuesEnumrVn sL!"rrZr N rrrrrrJrZrMmoderrrrvrvb s.  #INN #   2A 6$rrvcZeZdZdZej ddZejdZy)RemoveAclEntryResponseaResponse 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 rN) rrrrrrr/r0 aclDeletedrrrr^r^ s/  ua(#%y%%a(*rr^ceZdZdZy)rzRequest for RestartConnector.Nr4rrrrr &rrceZdZdZy)RestartConnectorResponsezResponse for RestartConnector.Nr4rrrrcrc s'rrcceZdZdZy)rzRequest for ResumeConnector.Nr4rrrrr rSrrceZdZdZy)ResumeConnectorResponsezResponse for ResumeConnector.Nr4rrrrfrf rarrfceZdZdZGddej ZejdddZejdZ ejdd Z y ) SchemaaSchema 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 eZdZdZdZdZdZdZy) Schema.SchemaTypeValueValuesEnumrArr rrNrBrrrrGrj rHrrGrIr Tr rrN) rrrrrrJrGrrKr"rLrMrNrrrrhrh sW  ).. &y%%&7TJ* 9  #&"y""#>B*rrhceZdZdZGddej ZejdZejddZ ejdZ y) SchemaConfiga7SchemaConfig 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. c,eZdZdZdZdZdZdZdZdZ dZ y ) )SchemaConfig.CompatibilityValueValuesEnumaRequired. 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 rrrrr N rrrrNONEBACKWARDBACKWARD_TRANSITIVEFORWARDFORWARD_TRANSITIVEFULLFULL_TRANSITIVErrrCompatibilityValueValuesEnumrn s. DHG DOrrwr rrN) rrrrrrJrwr"aliasrM compatibilityr0rrrrrlrl sR,Y^^0 )   "%%)%%&DaH-$i$$Q')rrlc`eZdZdZGddej ZejddZy) SchemaModeaSchemaMode 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 eZdZdZdZdZdZdZy)SchemaMode.ModeValueValuesEnumaRequired. 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 rrNrrrrrpREADONLY READWRITEIMPORTrrrrZr} s  DHI FrrZr Nr[rrrr{r{ s.(INN$   2A 6$rr{ceZdZdZej dZej dZejdejjZ y)rIzSchemaReference 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 rrrN) rrrrrr"r$rr7rrrrrrrIrI sM   q !$ !I ! !! $' "I " "1i.?.?.E.E F'rrIc\eZdZdZej ddZej dZy)raSchemaRegistry 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 rN)rrrrrr"contextsr$rrrrr( s/ #Y " "1t 4(   q !$rrcreZdZdZGddej ZejdejjZ ejddd Z ejd Zejdd Zejd Zejd ejjZy) SchemaVersionaVersion 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 eZdZdZdZdZdZdZy)'SchemaVersion.SchemaTypeValueValuesEnumrArr rrNrBrrrrGrG rHrrGr rrIrTr rrrr N)rrrrrrJrGr7rrrrrKr"rLrMrNrrrrrrr8 s  ).. ya):):)@)@A"%y%%&7TJ* 9  #&"y""#>B* !I ! !! $' "I " "1i.?.?.E.E F'rrc eZdZdZGddej ZGddej ZejddZ ejdZ ejddd Z ejd Z ejd Zejd ZejdZej"dd ZejdZejdZejdZejdZy)StandardQueryParametersa4Query 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"). ceZdZdZdZdZdZy)*StandardQueryParameters.AltValueValuesEnumzData 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 rN)rrrrjsonmediaprotorrrAltValueValuesEnumrx s D E ErrceZdZdZdZdZy)-StandardQueryParameters.FXgafvValueValuesEnumzVV1 error format. Values: _1: v1 error format _2: v2 error format rr N)rrrr_1_2rrrFXgafvValueValuesEnumr s B Brrr rrr)defaultrrr rurwTrxryrzr|N)rrrrrrJrrrMf__xgafvr" access_tokenaltcallbackfieldsrd oauth_tokenr0 prettyPrint quotaUsertrace uploadTypeupload_protocolrrrrr] s 4 9>>  inn !Y !8! <(&&&q), 0!VD# "Y " "1 %( 9  #& a #% %%a(+& &&q$7+#i##A&) )   #%$y$$R(*)I))"-/rrceZdZdZej dGddejZejdejjZ ejddd Zejd Zy ) rCaThe `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. r_cdeZdZdZGddej ZejdddZy)Status.DetailsValueListEntryzA DetailsValueListEntry object. Messages: AdditionalProperty: An additional property for a DetailsValueListEntry object. Fields: additionalProperties: Properties of the object. Contains field @type with type URL. cZeZdZdZej dZejddZy)/Status.DetailsValueListEntry.AdditionalPropertyzAn additional property for a DetailsValueListEntry object. Fields: key: Name of the additional property. value: A extra_types.JsonValue attribute. r rrNrrrrrfr rrrfr Tr NrgrrrDetailsValueListEntryr rrrr rrTr rN)rrrrrrrrhrr7rrcoderdetailsr"messagerrrrCrC s&"8!!"89Zi//Z:Z2   9+<+<+B+B C$ "I " "#:A M' !I ! !! $'rrCceZdZdZy)rzRequest for StopConnector.Nr4rrrrr s#rrceZdZdZy)StopConnectorResponsezResponse for StopConnector.Nr4rrrrr rPrrc|eZdZdZej dZej dZejdZ y)ra;Task 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 rrN) rrrrrr"maximumBackoffminimumBackoffr0taskRetryDisabledrrrrr s@()9((+.(9((+.,i,,Q/rrcZeZdZdZej dZejddZy)r{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 TrustConfigrN) rrrrrr"sslPrincipalMappingRulesr trustConfigrrrr{r{ s0 3Y2215& &&}a8+rr{cNeZdZdZej dGddejZejddZ ejdZ ejdejjZejd ejjZy ) raA 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. r_cdeZdZdZGddej ZejdddZy)Topic.ConfigsValueawOptional. 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 cXeZdZdZej dZej dZy)%Topic.ConfigsValue.AdditionalPropertyrr rNrprrrrfr+ rqrrfr Tr Nrgrrrrr rrrr rrrrN)rrrrrrrrhrrrr"r$r7rrpartitionCountreplicationFactorrrrrr s."8!!"89ZY&&Z:Z2 #I " ">1 5'   q !$)9))!Y5F5F5L5LM.,i,,Q 8I8I8O8OPrrc:eZdZdZej dddZy)rzSources of CA certificates to install in the broker's truststore. Fields: casConfigs: Optional. Configuration for the Google Certificate Authority Service. Maximum 10. r;r Tr N)rrrrrr casConfigsrrrrr> s!&y%%&I1W[\*rrc4eZdZdZej dZy)r}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 N)rrrrrr0$allowBrokerDownscaleOnClusterUpscalerrrr}r}I s *@)?)?)B&rr}ceZdZdZGddej ZejddZejdZ y)raRequest 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. c,eZdZdZdZdZdZdZdZdZ dZ y ) 6UpdateSchemaConfigRequest.CompatibilityValueValuesEnumaRequired. 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 rrrrr Nrorrrrwrp s.  DHG DOrrwr rN) rrrrrrJrwrMryr0rrrrrr[ s@(Y^^.&)%%&DaH-$i$$Q')rrc`eZdZdZGddej ZejddZy)rzRequest for updating schema registry or subject mode. Enums: ModeValueValuesEnum: Required. The mode type. Fields: mode: Required. The mode type. c eZdZdZdZdZdZdZy)+UpdateSchemaModeRequest.ModeValueValuesEnumaFRequired. 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 rrNr~rrrrZr s  DHI FrrZr Nr[rrrrr s.INN   2A 6$rrrz$.xgafvr1r2N)r __future__rapitools.base.protorpcliterrapitools.base.pyrrpackagerhr rrr.r3r6r;r>rQrTrrrrrrrrrrrrrrtrrrrrrr rrrr r%r*r1r5r9r;rArDrFrHrKrUrXr]r`rgrlrnrrrtrvrxrzr~rrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrr r rrrrrrrr!r#r%r'r)r,r.r0r2r4r6r rrHrrRrvr^rrcrrfrhrlr{rIrrrrCrrrr{rrr}rrAddCustomJsonFieldMappingAddCustomJsonEnumMappingrrrrrs  '<%(  M9$$ M+*)  +*\'y  '4 ))++ )=Y..= (Y&& ( $ (9(9 $& 1 1&D 5!2!2 5n)in)b T)++ Tl)Y&&l)^8y((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 8I8I1 '9J9J ' 1ZcZkZk1( 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