in src/Microsoft.Azure.WebJobs.Extensions.Kafka/Output/KafkaAttributeBinding.cs [27:49]
public KafkaAttributeBinding(
string parameterName,
KafkaAttribute attribute,
IKafkaProducerFactory kafkaProducerFactory,
IArgumentBinding<KafkaProducerEntity> argumentBinding,
Type keyType,
Type valueType,
string valueAvroSchema,
string keyAvroSchema,
IConfiguration config,
INameResolver nameResolver)
{
this.parameterName = parameterName;
this.attribute = attribute ?? throw new ArgumentNullException(nameof(attribute));
this.kafkaProducerFactory = kafkaProducerFactory ?? throw new ArgumentNullException(nameof(kafkaProducerFactory));
this.argumentBinding = argumentBinding ?? throw new ArgumentNullException(nameof(argumentBinding));
this.keyType = keyType;
this.valueType = valueType ?? throw new ArgumentNullException(nameof(valueType));
this.valueAvroSchema = valueAvroSchema;
this.keyAvroSchema = keyAvroSchema;
this.config = config;
this.nameResolver = nameResolver;
}