using System;

using Microsoft.Azure.WebJobs.Extensions.Kafka;

public class Program

{

    [Kafka(

                AuthenticationMode = BrokerAuthenticationMode.ScramSha512,

                AvroSchema = "AvroSchema",

                BrokerList = "BrokerList",

                BatchSize = 1,

                EnableIdempotence = true,

                MaxMessageBytes = 2,

                MaxRetries = 3,

                MessageTimeoutMs = 4,

                Password = "Password",

                Protocol = BrokerProtocol.SaslPlaintext,

                RequestTimeoutMs = 5,

                SslCaLocation = "SslCaLocation",

                SslCertificateLocation = "SslCertificateLocation",

                SslKeyLocation = "SslKeyLocation",

                SslKeyPassword = "SslKeyPassword",

                Username = "Username"

                    )]

    public static void Main()

    {

        Console.WriteLine("Hello World");

    }

}