internal static Type GetDataType()

in src/Microsoft.Azure.WebJobs.Extensions.Kafka/Extensions/KafkaMessageKeyTypeExtensions.cs [15:30]

• 16 lines of code
• 5 McCabe index (conditional complexity)

        internal static Type GetDataType(this KafkaMessageKeyType dataType)
        {
            switch (dataType)
            {
                case KafkaMessageKeyType.Int:
                    return typeof(int);
                case KafkaMessageKeyType.Long:
                    return typeof(long);
                case KafkaMessageKeyType.String:
                    return typeof(string);
                case KafkaMessageKeyType.Binary:
                    return typeof(byte[]);
                default:
                    throw new InvalidOperationException($"Unsupported KafkaMessageKeyType: {dataType}");
            }
        }