Skip to content

Class KafkaDependencyDefinition

Namespace: Cephalon.Observability.KafkaDependencies.Configuration
Assembly: Cephalon.Observability.KafkaDependencies.dll

Describes one Kafka dependency that should contribute to runtime health.

public sealed class KafkaDependencyDefinition : DependencyDefinitionBase

objectDependencyDefinitionBaseKafkaDependencyDefinition

DependencyDefinitionBase.Id, DependencyDefinitionBase.DisplayName, DependencyDefinitionBase.Required, DependencyDefinitionBase.TimeoutSeconds, object.Equals(object?), object.Equals(object?, object?), object.GetHashCode(), object.GetType(), object.ReferenceEquals(object?, object?), object.ToString()

Initializes a new instance of the class.

public KafkaDependencyDefinition()

Gets or sets the Kafka bootstrap server list, such as broker-1:9092,broker-2:9092.

public string BootstrapServers { get; set; }

string

Gets or sets the optional client identifier sent to the Kafka cluster.

public string? ClientId { get; set; }

string?

Gets or sets the optional SASL password used when authenticated broker access is required.

public string? Password { get; set; }

string?

Gets or sets the optional SASL mechanism, such as Plain, ScramSha256, or ScramSha512.

public string? SaslMechanism { get; set; }

string?

Gets or sets the optional Kafka security protocol, such as Plaintext, Ssl, SaslPlaintext, or SaslSsl.

public string? SecurityProtocol { get; set; }

string?

Gets or sets the optional topic name that should be present in returned cluster metadata.

public string? Topic { get; set; }

string?

Gets or sets the optional SASL user name used when authenticated broker access is required.

public string? Username { get; set; }

string?