public object Convert()

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;
            }