Managed Service for Apache Kafka API v1 API - Class TaskRetryPolicy (1.0.0-beta05) 

public sealed class TaskRetryPolicy : IMessage<TaskRetryPolicy>, IEquatable<TaskRetryPolicy>, IDeepCloneable<TaskRetryPolicy>, IBufferMessage, IMessage

Reference documentation and code samples for the Managed Service for Apache Kafka API v1 API class 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.

Inheritance

object > TaskRetryPolicy

Namespace

Google.Cloud.ManagedKafka.V1

Assembly

Google.Cloud.ManagedKafka.V1.dll

Constructors

TaskRetryPolicy()

public TaskRetryPolicy()

TaskRetryPolicy(TaskRetryPolicy)

public TaskRetryPolicy(TaskRetryPolicy other)
Parameter
Name Description
other TaskRetryPolicy

Properties

MaximumBackoff

public Duration MaximumBackoff { get; set; }

Optional. The maximum amount of time to wait before retrying a failed task. This sets an upper bound for the backoff delay.

Property Value
Type Description
Duration

MinimumBackoff

public Duration MinimumBackoff { get; set; }

Optional. The minimum amount of time to wait before retrying a failed task. This sets a lower bound for the backoff delay.

Property Value
Type Description
Duration