public KafkaEventData()

in src/Microsoft.Azure.WebJobs.Extensions.Kafka/KafkaEventData.cs [35:51]

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

        public KafkaEventData(ConsumeResult<TKey, TValue> consumeResult)
        {
            this.Key = consumeResult.Key;
            this.Value = consumeResult.Value;
            this.Offset = consumeResult.Offset;
            this.Partition = consumeResult.Partition;
            this.Timestamp = consumeResult.Message.Timestamp.UtcDateTime;
            this.Topic = consumeResult.Topic;
            if (consumeResult.Headers?.Count > 0)
            {
                this.Headers = new KafkaEventDataHeaders(consumeResult.Message.Headers);
            }
            else
            {
                this.Headers = KafkaEventDataHeaders.EmptyReadOnly;
            }
        }