Expand description
The messages and enums that are part of this client library.
Modules§
- cluster
- Defines additional types related to Cluster.
- connect_
cluster - Defines additional types related to ConnectCluster.
- connector
- Defines additional types related to Connector.
- rebalance_
config - Defines additional types related to RebalanceConfig.
- remove_
acl_ entry_ response - Defines additional types related to RemoveAclEntryResponse.
- trust_
config - Defines additional types related to TrustConfig.
Structs§
- Access
Config - 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.
- AddAcl
Entry Request - Request for AddAclEntry.
- AddAcl
Entry Response - Response for AddAclEntry.
- Capacity
Config - A capacity configuration of a Kafka cluster.
- Cluster
- An Apache Kafka cluster deployed in a location.
- Connect
Access Config - The configuration of access to the Kafka Connect cluster.
- Connect
Cluster - An Apache Kafka Connect cluster deployed in a location.
- Connect
GcpConfig - Configuration properties for a Kafka Connect cluster deployed to Google Cloud Platform.
- Connect
Network Config - 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.
- Consumer
Group - A Kafka consumer group in a given cluster.
- Consumer
Partition Metadata - Metadata for a consumer group corresponding to a specific partition.
- Consumer
Topic Metadata - Metadata for a consumer group corresponding to a specific topic.
- Create
AclRequest - Request for CreateAcl.
- Create
Cluster Request - Request for CreateCluster.
- Create
Connect Cluster Request - Request for CreateConnectCluster.
- Create
Connector Request - Request for CreateConnector.
- Create
Topic Request - Request for CreateTopic.
- Delete
AclRequest - Request for DeleteAcl.
- Delete
Cluster Request - Request for DeleteCluster.
- Delete
Connect Cluster Request - Request for DeleteConnectCluster.
- Delete
Connector Request - Request for DeleteConnector.
- Delete
Consumer Group Request - Request for DeleteConsumerGroup.
- Delete
Topic Request - Request for DeleteTopic.
- GcpConfig
- Configuration properties for a Kafka cluster deployed to Google Cloud Platform.
- GetAcl
Request - Request for GetAcl.
- GetCluster
Request - Request for GetCluster.
- GetConnect
Cluster Request - Request for GetConnectCluster.
- GetConnector
Request - Request for GetConnector.
- GetConsumer
Group Request - Request for GetConsumerGroup.
- GetTopic
Request - Request for GetTopic.
- List
Acls Request - Request for ListAcls.
- List
Acls Response - Response for ListAcls.
- List
Clusters Request - Request for ListClusters.
- List
Clusters Response - Response for ListClusters.
- List
Connect Clusters Request - Request for ListConnectClusters.
- List
Connect Clusters Response - Response for ListConnectClusters.
- List
Connectors Request - Request for ListConnectors.
- List
Connectors Response - Response for ListConnectors.
- List
Consumer Groups Request - Request for ListConsumerGroups.
- List
Consumer Groups Response - Response for ListConsumerGroups.
- List
Topics Request - Request for ListTopics.
- List
Topics Response - Response for ListTopics.
- Network
Config - The configuration of a Virtual Private Cloud (VPC) network that can access the Kafka cluster.
- Operation
Metadata - Represents the metadata of the long-running operation.
- Pause
Connector Request - Request for PauseConnector.
- Pause
Connector Response - Response for PauseConnector.
- Rebalance
Config - Defines rebalancing behavior of a Kafka cluster.
- Remove
AclEntry Request - Request for RemoveAclEntry.
- Remove
AclEntry Response - Response for RemoveAclEntry.
- Restart
Connector Request - Request for RestartConnector.
- Restart
Connector Response - Response for RestartConnector.
- Resume
Connector Request - Request for ResumeConnector.
- Resume
Connector Response - Response for ResumeConnector.
- Stop
Connector Request - Request for StopConnector.
- Stop
Connector Response - Response for StopConnector.
- Task
Retry Policy - 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.
- Trust
Config - Sources of CA certificates to install in the broker’s truststore.
- Update
AclRequest - Request for UpdateAcl.
- Update
Cluster Request - Request for UpdateCluster.
- Update
Connect Cluster Request - Request for UpdateConnectCluster.
- Update
Connector Request - Request for UpdateConnector.
- Update
Consumer Group Request - Request for UpdateConsumerGroup.
- Update
Topic Request - Request for UpdateTopic.