internal static void AddBindingData()

in src/Microsoft.Azure.WebJobs.Extensions.Kafka/Trigger/KafkaTriggerBindingStrategy.cs [89:115]

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

        internal static void AddBindingData(Dictionary<string, object> bindingData, IKafkaEventData[] events)
        {
            int length = events.Length;
            var partitions = new int[length];
            var offsets = new long[length];
            var timestamps = new DateTime[length];
            var topics = new string[length];
            var keys = new object[length];
            var headers = new object[length];

            bindingData.Add("PartitionArray", partitions);
            bindingData.Add("OffsetArray", offsets);
            bindingData.Add("TimestampArray", timestamps);
            bindingData.Add("TopicArray", topics);
            bindingData.Add("KeyArray", keys);
            bindingData.Add("HeadersArray", headers);

            for (int i = 0; i < events.Length; i++)
            {
                partitions[i] = events[i].Partition;
                offsets[i] = events[i].Offset;
                timestamps[i] = events[i].Timestamp;
                keys[i] = HandleKeyDataConversion(events[i].Key);
                topics[i] = events[i].Topic;
                headers[i] = events[i].Headers;
            }
        }