in src/Microsoft.Azure.WebJobs.Extensions.Kafka/Trigger/KafkaListenerConfiguration.cs [173:194]
internal void ApplyToConfig(ClientConfig conf)
{
if (this.SaslMechanism.HasValue)
{
conf.SaslMechanism = this.SaslMechanism.Value;
}
if (!string.IsNullOrWhiteSpace(this.SaslUsername))
{
conf.SaslUsername = this.SaslUsername;
}
if (!string.IsNullOrWhiteSpace(this.SaslPassword))
{
conf.SaslPassword = this.SaslPassword;
}
if (this.SecurityProtocol.HasValue)
{
conf.SecurityProtocol = this.SecurityProtocol.Value;
}
}