Package Classes (0.1.9)

Stay organized with collections Save and categorize content based on your preferences.

The service that a client application uses to manage Apache Kafka clusters, topics and consumer groups.

The service that a client application uses to manage Apache Kafka clusters, topics and consumer groups.

A pager for iterating through list_clusters requests.

This class thinly wraps an initial ListClustersResponse object, and provides an __aiter__ method to iterate through its clusters field.

If there are more pages, the __aiter__ method will make additional ListClusters requests and continue to iterate through the clusters field on the corresponding responses.

All the usual ListClustersResponse attributes are available on the pager. If multiple requests are made, only the most recent response is retained, and thus used for attribute lookup.

A pager for iterating through list_clusters requests.

This class thinly wraps an initial ListClustersResponse object, and provides an __iter__ method to iterate through its clusters field.

If there are more pages, the __iter__ method will make additional ListClusters requests and continue to iterate through the clusters field on the corresponding responses.

All the usual ListClustersResponse attributes are available on the pager. If multiple requests are made, only the most recent response is retained, and thus used for attribute lookup.

A pager for iterating through list_consumer_groups requests.

This class thinly wraps an initial ListConsumerGroupsResponse object, and provides an __aiter__ method to iterate through its consumer_groups field.

If there are more pages, the __aiter__ method will make additional ListConsumerGroups requests and continue to iterate through the consumer_groups field on the corresponding responses.

All the usual ListConsumerGroupsResponse attributes are available on the pager. If multiple requests are made, only the most recent response is retained, and thus used for attribute lookup.

A pager for iterating through list_consumer_groups requests.

This class thinly wraps an initial ListConsumerGroupsResponse object, and provides an __iter__ method to iterate through its consumer_groups field.

If there are more pages, the __iter__ method will make additional ListConsumerGroups requests and continue to iterate through the consumer_groups field on the corresponding responses.

All the usual ListConsumerGroupsResponse attributes are available on the pager. If multiple requests are made, only the most recent response is retained, and thus used for attribute lookup.

A pager for iterating through list_topics requests.

This class thinly wraps an initial ListTopicsResponse object, and provides an __aiter__ method to iterate through its topics field.

If there are more pages, the __aiter__ method will make additional ListTopics requests and continue to iterate through the topics field on the corresponding responses.

All the usual ListTopicsResponse attributes are available on the pager. If multiple requests are made, only the most recent response is retained, and thus used for attribute lookup.

A pager for iterating through list_topics requests.

This class thinly wraps an initial ListTopicsResponse object, and provides an __iter__ method to iterate through its topics field.

If there are more pages, the __iter__ method will make additional ListTopics requests and continue to iterate through the topics field on the corresponding responses.

All the usual ListTopicsResponse attributes are available on the pager. If multiple requests are made, only the most recent response is retained, and thus used for attribute lookup.

The service that a client application uses to manage Apache Kafka Connect clusters and connectors.

The service that a client application uses to manage Apache Kafka Connect clusters and connectors.

A pager for iterating through list_connect_clusters requests.

This class thinly wraps an initial ListConnectClustersResponse object, and provides an __aiter__ method to iterate through its connect_clusters field.

If there are more pages, the __aiter__ method will make additional ListConnectClusters requests and continue to iterate through the connect_clusters field on the corresponding responses.

All the usual ListConnectClustersResponse attributes are available on the pager. If multiple requests are made, only the most recent response is retained, and thus used for attribute lookup.

A pager for iterating through list_connect_clusters requests.

This class thinly wraps an initial ListConnectClustersResponse object, and provides an __iter__ method to iterate through its connect_clusters field.

If there are more pages, the __iter__ method will make additional ListConnectClusters requests and continue to iterate through the connect_clusters field on the corresponding responses.

All the usual ListConnectClustersResponse attributes are available on the pager. If multiple requests are made, only the most recent response is retained, and thus used for attribute lookup.

A pager for iterating through list_connectors requests.

This class thinly wraps an initial ListConnectorsResponse object, and provides an __aiter__ method to iterate through its connectors field.

If there are more pages, the __aiter__ method will make additional ListConnectors requests and continue to iterate through the connectors field on the corresponding responses.

All the usual ListConnectorsResponse attributes are available on the pager. If multiple requests are made, only the most recent response is retained, and thus used for attribute lookup.

A pager for iterating through list_connectors requests.

This class thinly wraps an initial ListConnectorsResponse object, and provides an __iter__ method to iterate through its connectors field.

If there are more pages, the __iter__ method will make additional ListConnectors requests and continue to iterate through the connectors field on the corresponding responses.

All the usual ListConnectorsResponse attributes are available on the pager. If multiple requests are made, only the most recent response is retained, and thus used for attribute lookup.

The configuration of access to the Kafka cluster.

A capacity configuration of a Kafka cluster.

An Apache Kafka cluster deployed in a location.

.. _oneof: https://proto-plus-python.readthedocs.io/en/stable/fields.html#oneofs-mutually-exclusive-fields

The abstract base class for a message.

The state of the cluster.

The configuration of access to the Kafka Connect cluster.

An Apache Kafka Connect cluster deployed in a location.

.. _oneof: https://proto-plus-python.readthedocs.io/en/stable/fields.html#oneofs-mutually-exclusive-fields

The abstract base class for a message.

The abstract base class for a message.

The state of the cluster.

Configuration properties for a Kafka Connect cluster deployed to Google Cloud Platform.

The configuration of a Virtual Private Cloud (VPC) network that can access the Kafka Connect cluster.

A Kafka Connect connector in a given ConnectCluster.

.. _oneof: https://proto-plus-python.readthedocs.io/en/stable/fields.html#oneofs-mutually-exclusive-fields

The abstract base class for a message.

The state of the connector.

A Kafka consumer group in a given cluster.

The abstract base class for a message.

Metadata for a consumer group corresponding to a specific partition.

Metadata for a consumer group corresponding to a specific topic.

The abstract base class for a message.

Request for CreateCluster.

Request for CreateConnectCluster.

Request for CreateConnector.

Request for CreateTopic.

Request for DeleteCluster.

Request for DeleteConnectCluster.

Request for DeleteConnector.

Request for DeleteConsumerGroup.

Request for DeleteTopic.

Configuration properties for a Kafka cluster deployed to Google Cloud Platform.

Request for GetCluster.

Request for GetConnectCluster.

Request for GetConnector.

Request for GetConsumerGroup.

Request for GetTopic.

Request for ListClusters.

Response for ListClusters.

Request for ListConnectClusters.

Response for ListConnectClusters.

Request for ListConnectors.

Response for ListConnectors.

Request for ListConsumerGroups.

Response for ListConsumerGroups.

Request for ListTopics.

Response for ListTopics.

The configuration of a Virtual Private Cloud (VPC) network that can access the Kafka cluster.

Represents the metadata of the long-running operation.

Request for PauseConnector.

Response for PauseConnector.

Defines rebalancing behavior of a Kafka cluster.

The partition rebalance mode for the cluster.

Request for RestartConnector.

Response for RestartConnector.

Request for ResumeConnector.

Response for ResumeConnector.

Request for StopConnector.

Response for StopConnector.

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.

A Kafka topic in a given cluster.

The abstract base class for a message.

Request for UpdateCluster.

Request for UpdateConnectCluster.

Request for UpdateConnector.

Request for UpdateConsumerGroup.

Request for UpdateTopic.

API documentation for managedkafka_v1.services.managed_kafka.pagers module.

API documentation for managedkafka_v1.services.managed_kafka_connect.pagers module.