in src/Microsoft.Azure.WebJobs.Extensions.Kafka/Output/KafkaEventDataArgumentBindingProvider.cs [11:30]
public IArgumentBinding<KafkaProducerEntity> TryCreate(ParameterInfo parameter)
{
if (!parameter.IsOut)
{
return null;
}
var parameterType = parameter.ParameterType;
while (parameterType.HasElementType)
{
parameterType = parameterType.GetElementType();
}
if (!parameterType.IsGenericType || !typeof(IKafkaEventData).IsAssignableFrom(parameterType))
{
return null;
}
return new KafkaEventDataArgumentBinding();
}