Class KafkaOptions

Provides shared Kafka broker connection settings used by Kafka sources and destinations.

public class KafkaOptions

Inherited Members: object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Properties

Gets or sets the SASL password used when the selected security protocol requires authentication.

public string BootstrapPassword { get; set; }

Gets or sets the bootstrap broker list used to connect to the Kafka cluster.

public string BootstrapServers { get; set; }

Gets or sets the SASL username used when the selected security protocol requires authentication.

public string BootstrapUser { get; set; }

Gets or sets the SASL mechanism used when SASL authentication is enabled.

public SaslMechanism SaslMechanism { get; set; }

Gets or sets the transport security protocol used for the Kafka connection.

public SecurityProtocol SecurityProtocol { get; set; }