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


Reply via email to