Namespace google::cloud::managedkafka_v1 (2.27.0-rc)

Classes

ManagedKafkaClient

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

ManagedKafkaConnection

The ManagedKafkaConnection object for ManagedKafkaClient.

ManagedKafkaConnectionIdempotencyPolicy

ManagedKafkaLimitedErrorCountRetryPolicy

A retry policy for ManagedKafkaConnection based on counting errors.

ManagedKafkaLimitedTimeRetryPolicy

A retry policy for ManagedKafkaConnection based on elapsed time.

ManagedKafkaRetryPolicy

The retry policy for ManagedKafkaConnection.

Structs

ManagedKafkaBackoffPolicyOption

Use with google::cloud::Options to configure the backoff policy.

ManagedKafkaConnectionIdempotencyPolicyOption

Use with google::cloud::Options to configure which operations are retried.

ManagedKafkaPollingPolicyOption

Use with google::cloud::Options to configure the long-running operations polling policy.

ManagedKafkaRetryPolicyOption

Use with google::cloud::Options to configure the retry policy.

Functions

MakeManagedKafkaConnection(Options)

A factory function to construct an object of type ManagedKafkaConnection.

The returned connection object should not be used directly; instead it should be passed as an argument to the constructor of ManagedKafkaClient.

The optional options argument may be used to configure aspects of the returned ManagedKafkaConnection. Expected options are any of the types in the following option lists:

Parameter
Name Description
options

(optional) Configure the ManagedKafkaConnection created by this function.

Returns
Type Description
std::shared_ptr< ManagedKafkaConnection >

MakeDefaultManagedKafkaConnectionIdempotencyPolicy()

Returns
Type Description
std::unique_ptr< ManagedKafkaConnectionIdempotencyPolicy >