internal static KafkaEventData CreateFrom()

in src/Microsoft.Azure.WebJobs.Extensions.Kafka/KafkaEventData.cs [85:108]

• 22 lines of code
• 2 McCabe index (conditional complexity)

        internal static KafkaEventData<TValue> CreateFrom<TKey>(ConsumeResult<TKey, TValue> consumeResult)
        {
            KafkaEventDataHeaders headers;
            if (consumeResult.Headers?.Count > 0)
            {
                headers = new KafkaEventDataHeaders(consumeResult.Message.Headers);
            }
            else
            {
                headers = KafkaEventDataHeaders.EmptyReadOnly;
            }

            var result = new KafkaEventData<TValue>(headers)
            {
                Value = consumeResult.Value,
                Offset = consumeResult.Offset,
                Partition = consumeResult.Partition,
                Timestamp = consumeResult.Timestamp.UtcDateTime,
                Topic = consumeResult.Topic,
                Key = consumeResult.Key
            };

            return result;
        }