naresh8095188035 / Kerbarosed_Kafka

0 stars 0 forks source link

Not Able to send message to the Kerbarised Kafka consumer from .NET core Producer #1

Open naresh8095188035 opened 6 years ago

naresh8095188035 commented 6 years ago

Not Able to send message to the Kerbarised Kafka consumer from .NET core Producer

Producer code is below: I have tried commented parameters also: var config = new Dictionary<string, object> {

                //{ "client.id", "clientid"},
                //{ "bootstrap.servers", "vasppe.kafka01.local" },
                //{ "security.protocol","SASL_PLAINTEXT"},
                //{ "sasl.mechanisms", "GSSAPI"},
                //{ "debug","all"},
                //{ "sasl.kerberos.service.name", "kafka"} ,
                //{ "api.version.request", "true" },
                //{ "default.topic.config", new Dictionary<string, object>()
                //    {
                //        { "auto.offset.reset", "smallest" }
                //    }
                //}

                { "bootstrap.servers", "vasppe.kafka01.local"},
                { "client.id", "clientid"},
                { "api.version.request", "true" },
                { "security.protocol","SASL_PLAINTEXT"},
                { "sasl.mechanisms", "GSSAPI"},
                { "sasl.kerberos.service.name", "kafka"}

                //{ "bootstrap.servers", "10.253.14.117:6668"     },
                //{ "client.id", "1"},
                //{ "api.version.request", "true" },
                //{ "security.protocol","sasl_ssl"},
                //{ "sasl.mechanisms", "GSSAPI"},
                //{ "sasl.kerberos.principal", "naresh.s.afzalpurkar@NEXTGEN.LOCAL"},
                //{ "enable.auto.commit", true },
                //{ "session.timeout.ms", "15000" },
                //{"acks", "all" },
                //{"max.in.flight.requests.per.connection" , "1" }// to send one request at a time

                //{ "group.id", "simple-csharp-consumer" },
                //{ "client.id", "clientid"},
                //{ "bootstrap.servers", "10.253.14.117:6668" },
                //{ "security.protocol","SASL_PLAINTEXT"},
                //{ "sasl.mechanisms", "GSSAPI"},
                //{ "debug","all"},
                //{ "sasl.kerberos.service.name", "kafka"} ,
                //{ "api.version.request", "true" },
                //{ "auto.offset.reset", "smallest" }

                //{ "bootstrap.servers", "10.253.14.124:9092" },
                //{ "client.id", "clientid"},
                //{ "api.version.request", "true" },
                //{ "security.protocol","SASL_PLAINTEXT"},
                //{ "sasl.mechanisms", "GSSAPI"},
                //{ "sasl.kerberos.principal", "naresh.s.afzalpurkar@NEXTGEN.LOCAL"}
            };
naresh8095188035 commented 6 years ago

Please suggest on same...