Classes
AccessConfig
The configuration of access to the Kafka cluster.
Acl
Represents the set of ACLs for a given Kafka Resource Pattern, which consists of resource_type, resource_name and pattern_type.
AclEntry
Represents the access granted for a given Resource Pattern in an ACL.
AclName
Resource name for the Acl resource.
AddAclEntryRequest
Request for AddAclEntry.
AddAclEntryResponse
Response for AddAclEntry.
CaPoolName
Resource name for the CaPool resource.
CapacityConfig
A capacity configuration of a Kafka cluster.
Cluster
An Apache Kafka cluster deployed in a location.
Cluster.Types
Container for nested types declared in the Cluster message type.
ClusterName
Resource name for the Cluster resource.
ConnectAccessConfig
The configuration of access to the Kafka Connect cluster.
ConnectCluster
An Apache Kafka Connect cluster deployed in a location.
ConnectCluster.Types
Container for nested types declared in the ConnectCluster message type.
ConnectClusterName
Resource name for the ConnectCluster resource.
ConnectGcpConfig
Configuration properties for a Kafka Connect cluster deployed to Google Cloud Platform.
ConnectNetworkConfig
The configuration of a Virtual Private Cloud (VPC) network that can access the Kafka Connect cluster.
Connector
A Kafka Connect connector in a given ConnectCluster.
Connector.Types
Container for nested types declared in the Connector message type.
ConnectorName
Resource name for the Connector resource.
ConsumerGroup
A Kafka consumer group in a given cluster.
ConsumerGroupName
Resource name for the ConsumerGroup resource.
ConsumerPartitionMetadata
Metadata for a consumer group corresponding to a specific partition.
ConsumerTopicMetadata
Metadata for a consumer group corresponding to a specific topic.
CreateAclRequest
Request for CreateAcl.
CreateClusterRequest
Request for CreateCluster.
CreateConnectClusterRequest
Request for CreateConnectCluster.
CreateConnectorRequest
Request for CreateConnector.
CreateTopicRequest
Request for CreateTopic.
CryptoKeyName
Resource name for the CryptoKey resource.
DeleteAclRequest
Request for DeleteAcl.
DeleteClusterRequest
Request for DeleteCluster.
DeleteConnectClusterRequest
Request for DeleteConnectCluster.
DeleteConnectorRequest
Request for DeleteConnector.
DeleteConsumerGroupRequest
Request for DeleteConsumerGroup.
DeleteTopicRequest
Request for DeleteTopic.
GcpConfig
Configuration properties for a Kafka cluster deployed to Google Cloud Platform.
GetAclRequest
Request for GetAcl.
GetClusterRequest
Request for GetCluster.
GetConnectClusterRequest
Request for GetConnectCluster.
GetConnectorRequest
Request for GetConnector.
GetConsumerGroupRequest
Request for GetConsumerGroup.
GetTopicRequest
Request for GetTopic.
ListAclsRequest
Request for ListAcls.
ListAclsResponse
Response for ListAcls.
ListClustersRequest
Request for ListClusters.
ListClustersResponse
Response for ListClusters.
ListConnectClustersRequest
Request for ListConnectClusters.
ListConnectClustersResponse
Response for ListConnectClusters.
ListConnectorsRequest
Request for ListConnectors.
ListConnectorsResponse
Response for ListConnectors.
ListConsumerGroupsRequest
Request for ListConsumerGroups.
ListConsumerGroupsResponse
Response for ListConsumerGroups.
ListTopicsRequest
Request for ListTopics.
ListTopicsResponse
Response for ListTopics.
ManagedKafka
The service that a client application uses to manage Apache Kafka clusters, topics and consumer groups.
ManagedKafka.ManagedKafkaBase
Base class for server-side implementations of ManagedKafka
ManagedKafka.ManagedKafkaClient
Client for ManagedKafka
ManagedKafkaClient
ManagedKafka client wrapper, for convenient use.
ManagedKafkaClientBuilder
Builder class for ManagedKafkaClient to provide simple configuration of credentials, endpoint etc.
ManagedKafkaClientImpl
ManagedKafka client wrapper implementation, for convenient use.
ManagedKafkaConnect
The service that a client application uses to manage Apache Kafka Connect clusters and connectors.
ManagedKafkaConnect.ManagedKafkaConnectBase
Base class for server-side implementations of ManagedKafkaConnect
ManagedKafkaConnect.ManagedKafkaConnectClient
Client for ManagedKafkaConnect
ManagedKafkaConnectClient
ManagedKafkaConnect client wrapper, for convenient use.
ManagedKafkaConnectClientBuilder
Builder class for ManagedKafkaConnectClient to provide simple configuration of credentials, endpoint etc.
ManagedKafkaConnectClientImpl
ManagedKafkaConnect client wrapper implementation, for convenient use.
ManagedKafkaConnectSettings
Settings for ManagedKafkaConnectClient instances.
ManagedKafkaSettings
Settings for ManagedKafkaClient instances.
NetworkConfig
The configuration of a Virtual Private Cloud (VPC) network that can access the Kafka cluster.
OperationMetadata
Represents the metadata of the long-running operation.
PauseConnectorRequest
Request for PauseConnector.
PauseConnectorResponse
Response for PauseConnector.
RebalanceConfig
Defines rebalancing behavior of a Kafka cluster.
RebalanceConfig.Types
Container for nested types declared in the RebalanceConfig message type.
RemoveAclEntryRequest
Request for RemoveAclEntry.
RemoveAclEntryResponse
Response for RemoveAclEntry.
RestartConnectorRequest
Request for RestartConnector.
RestartConnectorResponse
Response for RestartConnector.
ResumeConnectorRequest
Request for ResumeConnector.
ResumeConnectorResponse
Response for ResumeConnector.
SecretVersionName
Resource name for the SecretVersion resource.
StopConnectorRequest
Request for StopConnector.
StopConnectorResponse
Response for StopConnector.
TaskRetryPolicy
Task Retry Policy is implemented on a best-effort basis. 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 30 minutes respectively.
TlsConfig
The TLS configuration for the Kafka cluster.
Topic
A Kafka topic in a given cluster.
TopicName
Resource name for the Topic resource.
TrustConfig
Sources of CA certificates to install in the broker's truststore.
TrustConfig.Types
Container for nested types declared in the TrustConfig message type.
TrustConfig.Types.CertificateAuthorityServiceConfig
A configuration for the Google Certificate Authority Service.
UpdateAclRequest
Request for UpdateAcl.
UpdateClusterRequest
Request for UpdateCluster.
UpdateConnectClusterRequest
Request for UpdateConnectCluster.
UpdateConnectorRequest
Request for UpdateConnector.
UpdateConsumerGroupRequest
Request for UpdateConsumerGroup.
UpdateTopicRequest
Request for UpdateTopic.
Enums
AclName.ResourceNameType
The possible contents of AclName.
CaPoolName.ResourceNameType
The possible contents of CaPoolName.
Cluster.PlatformConfigOneofCase
Enum of possible cases for the "platform_config" oneof.
Cluster.Types.State
The state of the cluster.
ClusterName.ResourceNameType
The possible contents of ClusterName.
ConnectCluster.PlatformConfigOneofCase
Enum of possible cases for the "platform_config" oneof.
ConnectCluster.Types.State
The state of the cluster.
ConnectClusterName.ResourceNameType
The possible contents of ConnectClusterName.
Connector.RestartPolicyOneofCase
Enum of possible cases for the "restart_policy" oneof.
Connector.Types.State
The state of the connector.
ConnectorName.ResourceNameType
The possible contents of ConnectorName.
ConsumerGroupName.ResourceNameType
The possible contents of ConsumerGroupName.
CryptoKeyName.ResourceNameType
The possible contents of CryptoKeyName.
RebalanceConfig.Types.Mode
The partition rebalance mode for the cluster.
RemoveAclEntryResponse.ResultOneofCase
Enum of possible cases for the "result" oneof.
SecretVersionName.ResourceNameType
The possible contents of SecretVersionName.
TopicName.ResourceNameType
The possible contents of TopicName.