You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@kafka.apache.org by "Kudumula, Surender" <su...@hpe.com> on 2015/11/06 08:52:59 UTC

Producing messages to secured kafka from different node java client in a cluster

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