private object BuildKafkaDataEvent()

in src/Microsoft.Azure.WebJobs.Extensions.Kafka/Output/KafkaProducerAsyncCollector.cs [88:101]

• 14 lines of code
• 8 McCabe index (conditional complexity)

            private object BuildKafkaDataEvent(T item)
            {
                JObject dataObj = JObject.Parse(item.ToString());
                if (dataObj == null)
                {
                    return new KafkaEventData<T>(item);
                }
                if (dataObj.ContainsKey("Offset") && dataObj.ContainsKey("Partition") && dataObj.ContainsKey("Topic")
                    && dataObj.ContainsKey("Timestamp") && dataObj.ContainsKey("Value") && dataObj.ContainsKey("Headers"))
                {
                    return BuildKafkaEventData(dataObj);
                }
                return new KafkaEventData<T>(item);
            }