Hi Tao, As you say, security protocols are not currently pluggable. `ChannelBuilder` is already an interface, but `SecurityProtocol` is an enum, which makes it hard for users to add additional security protocols. Changing this would probably require a KIP:
https://cwiki.apache.org/confluence/display/KAFKA/Kafka+Improvement+Proposals Ismael On Mon, Jan 18, 2016 at 3:15 AM, tao xiao <xiaotao...@gmail.com> wrote: > Hi Kafka team, > > I want to know if I can plug-in my own security protocol to Kafka to > implement project specific authentication mechanism. The current supported > authentication protocols, SASL/GSSAPI and SSL, are not supported in my > company and we have own security protocol to do authentication. > > Is it a good idea to make ChannelBuilder extensible so that I can implement > it with my own security channel? >
