var clientConfig = new PulsarClientConfigBuilder()
                .ServiceUrl(endPoint)
                .ConnectionsPerBroker(1)
                //If Broker is behind proxy, set that in the Client Configuration
                .UseProxy(true)
                .OperationTimeout(opto)
                .AllowTlsInsecureConnection(false)
                .ProxyServiceUrl(url, ProxyProtocol.SNI)
                .Authentication( new AuthenticationDisabled())                             //.Authentication(AuthenticationFactory.Token("eyJhbGciOiJSUzI1NiJ9.eyJzdWIiOiJzaGFycHB1bHNhci1jbGllbnQtNWU3NzY5OWM2M2Y5MCJ9.lbwoSdOdBoUn3yPz16j3V7zvkUx-Xbiq0_vlSvklj45Bo7zgpLOXgLDYvY34h4MX8yHB4ynBAZEKG1ySIv76DPjn6MIH2FTP_bpI4lSvJxF5KsuPlFHsj8HWTmk57TeUgZ1IOgQn0muGLK1LhrRzKOkdOU6VBV_Hu0Sas0z9jTZL7Xnj1pTmGAn1hueC-6NgkxaZ-7dKqF4BQrr7zNt63_rPZi0ev47vcTV3ga68NUYLH5PfS8XIqJ_OV7ylouw1qDrE9SVN8a5KRrz8V3AokjThcsJvsMQ8C1MhbEm88QICdNKF5nu7kPYR6SsOfJJ1HYY-QBX3wf6YO3VAF_fPpQ"))
                .ClientConfigurationData;

var pulsarSystem = PulsarSystem.GetInstance(clientConfig);

           var jsonSchem = AvroSchema.Of(typeof(Students));
            var producerListener = new DefaultProducerListener((o) =>
            {
                Console.WriteLine(o.ToString());
            }, s =>
            {
                Receipts.Add(s);
            });
            var producerConfig = new ProducerConfigBuilder()
                .ProducerName($"Test-{topic}-{Guid.NewGuid()}")
                .Topic(topic)
                .Schema(jsonSchem)
                .EnableChunking(true)
                .EventListener(producerListener)
                .ProducerConfigurationData;

            var t = pulsarSystem.PulsarProducer(new CreateProducer(jsonSchem, producerConfig));            
            Console.WriteLine($"Acquired producer for topic: {t.Topic}");
            SendMessages(system, topic, t.Producer, key, value, tag);

           var consumerListener = new DefaultConsumerEventListener(Console.WriteLine);
            var messageListener = new DefaultMessageListener(StudentHandler, null);
            var jsonSchem = AvroSchema.Of(typeof(Students));
            var topicLast = topic.Split("/").Last();
            var consumerConfig = new ConsumerConfigBuilder()
                .ConsumerName(topicLast)
                .ForceTopicCreation(true)
                .SubscriptionName($"{topicLast}-Subscription")
                .Topic(topic)
                //.AckTimeout(10000)
                .AcknowledgmentGroupTime(0)
                .ConsumerEventListener(consumerListener)
                .SubscriptionType(CommandSubscribe.SubType.Exclusive)
                .Schema(jsonSchem)
                .SetConsumptionType(ConsumptionType.Queue)
                .MessageListener(messageListener)
                .StartMessageId(MessageIdFields.Earliest)
                .SubscriptionInitialPosition(SubscriptionInitialPosition.Earliest)
                .ConsumerConfigurationData;
            system.PulsarConsumer(new CreateConsumer(jsonSchem, consumerConfig));