Hi all Trying to produce message to secured HDP2.3 kakfa broker from different node using a java producer client but facing below issue any ideas how to configure Kerberos so that I can produce messages to kafka. Thank you.
[2015-11-06 07:18:57,435] INFO Closing socket connection to /10.0.2.17. (kafka.network.Processor) [2015-11-06 07:18:57,630] ERROR Closing socket for /10.0.2.40 because of error (kafka.network.Processor) java.io.IOException: javax.security.sasl.SaslException: GSS initiate failed [Caused by GSSException: Defective token detected (Mechanism level: GSSHeader did not find the right tag)] at org.apache.kafka.common.network.SaslServerAuthenticator.authenticate(SaslServerAuthenticator.java:192) at org.apache.kafka.common.network.Channel.connect(Channel.java:71) at kafka.network.Processor.handshake(SocketServer.scala:518) at kafka.network.Processor.run(SocketServer.scala:407) at java.lang.Thread.run(Thread.java:745) Caused by: javax.security.sasl.SaslException: GSS initiate failed [Caused by GSSException: Defective token detected (Mechanism level: GSSHeader did not find the right tag)] at com.sun.security.sasl.gsskerb.GssKrb5Server.evaluateResponse(GssKrb5Server.java:177) at org.apache.kafka.common.network.SaslServerAuthenticator.authenticate(SaslServerAuthenticator.java:182) ... 4 more Caused by: GSSException: Defective token detected (Mechanism level: GSSHeader did not find the right tag) at sun.security.jgss.GSSHeader.<init>(GSSHeader.java:97) at sun.security.jgss.GSSContextImpl.acceptSecContext(GSSContextImpl.java:306) at sun.security.jgss.GSSContextImpl.acceptSecContext(GSSContextImpl.java:285) at com.sun.security.sasl.gsskerb.GssKrb5Server.evaluateResponse(GssKrb5Server.java:155) ... 5 more [2015-11-06 07:18:57,742] ERROR Closing socket for /10.0.2.40 because of error (kafka.network.Processor) java.io.IOException: javax.security.sasl.SaslException: GSS initiate failed [Caused by GSSException: Defective token detected (Mechanism level: GSSHeader did not find the right tag)] at org.apache.kafka.common.network.SaslServerAuthenticator.authenticate(SaslServerAuthenticator.java:192) at org.apache.kafka.common.network.Channel.connect(Channel.java:71) at kafka.network.Processor.handshake(SocketServer.scala:518) at kafka.network.Processor.run(SocketServer.scala:407) at java.lang.Thread.run(Thread.java:745) Caused by: javax.security.sasl.SaslException: GSS initiate failed [Caused by GSSException: Defective token detected (Mechanism level: GSSHeader did not find the right tag)] at com.sun.security.sasl.gsskerb.GssKrb5Server.evaluateResponse(GssKrb5Server.java:177) at org.apache.kafka.common.network.SaslServerAuthenticator.authenticate(SaslServerAuthenticator.java:182) ... 4 more Caused by: GSSException: Defective token detected (Mechanism level: GSSHeader did not find the right tag) at sun.security.jgss.GSSHeader.<init>(GSSHeader.java:97) at sun.security.jgss.GSSContextImpl.acceptSecContext(GSSContextImpl.java:306) at sun.security.jgss.GSSContextImpl.acceptSecContext(GSSContextImpl.java:285) at com.sun.security.sasl.gsskerb.GssKrb5Server.evaluateResponse(GssKrb5Server.java:155) ... 5 more Regards Surender Kudumula