in src/Microsoft.Azure.WebJobs.Extensions.Kafka/Output/KafkaProducerAsyncCollector.cs [63:74]
public object Convert(T item)
{
if (item.GetType() == typeof(string))
{
return ConvertToKafkaEventData(item);
}
if (item.GetType() == typeof(byte[]))
{
return new KafkaEventData<T>(item);
}
return item;
}