in src/Microsoft.Azure.WebJobs.Extensions.Kafka/Output/CollectorValueProvider.cs [17:27]
public CollectorValueProvider(KafkaProducerEntity entity, object value, Type valueType)
{
if (value != null && !valueType.IsAssignableFrom(value.GetType()))
{
throw new InvalidOperationException("value is not of the correct type.");
}
this.entity = entity;
this.value = value;
this.valueType = valueType;
}