API documentation for managedkafka_v1.types package.
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.
AddAclEntryRequest
Request for AddAclEntry.
AddAclEntryResponse
Response for AddAclEntry.
CapacityConfig
A capacity configuration of a Kafka cluster.
Cluster
An Apache Kafka cluster deployed in a location.
.. _oneof: https://proto-plus-python.readthedocs.io/en/stable/fields.html#oneofs-mutually-exclusive-fields
ConnectAccessConfig
The configuration of access to the Kafka Connect cluster.
ConnectCluster
An Apache Kafka Connect cluster deployed in a location.
.. _oneof: https://proto-plus-python.readthedocs.io/en/stable/fields.html#oneofs-mutually-exclusive-fields
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.
.. _oneof: https://proto-plus-python.readthedocs.io/en/stable/fields.html#oneofs-mutually-exclusive-fields
ConsumerGroup
A Kafka consumer group in a given cluster.
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.
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.
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.
RemoveAclEntryRequest
Request for RemoveAclEntry.
RemoveAclEntryResponse
Response for RemoveAclEntry.
This message has oneof_ fields (mutually exclusive fields).
For each oneof, at most one member field can be set at the same time.
Setting any member of the oneof automatically clears all other
members.
.. _oneof: https://proto-plus-python.readthedocs.io/en/stable/fields.html#oneofs-mutually-exclusive-fields
RestartConnectorRequest
Request for RestartConnector.
RestartConnectorResponse
Response for RestartConnector.
ResumeConnectorRequest
Request for ResumeConnector.
ResumeConnectorResponse
Response for ResumeConnector.
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.
Topic
A Kafka topic in a given cluster.
UpdateAclRequest
Request for UpdateAcl.
UpdateClusterRequest
Request for UpdateCluster.
UpdateConnectClusterRequest
Request for UpdateConnectCluster.
UpdateConnectorRequest
Request for UpdateConnector.
UpdateConsumerGroupRequest
Request for UpdateConsumerGroup.
UpdateTopicRequest
Request for UpdateTopic.