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 |
| Returns | |
|---|---|
| Type | Description |
std::shared_ptr< ManagedKafkaConnection > |
|
MakeDefaultManagedKafkaConnectionIdempotencyPolicy()
| Returns | |
|---|---|
| Type | Description |
std::unique_ptr< ManagedKafkaConnectionIdempotencyPolicy > |
|