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.(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.(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

Hi All, In a cluster secured by Kerberos, the java code launch by a java action in job designer or oozie must pickup a Kerberos token. (HUE-1003) How do you actually do that? Can someone point me to an example or a tutorial? Thanks in advance, Matthieu Blanc
Hi, I have encountered situation where cluster client stops receiving messages from one of the cluster nodes after that node is restarted. My setup:                             ___ Node 1 ___ Cluster Client  ---/                                                                                                                                     
Hi All,   I could able to connect the hadoop (source ) cluster after ssh is established. But i wanted to know, If I want to pull some data using distcp from source secured hadoop box to another hadoop cluster , I could not able to ping  name node machine.  In this approach how to run distcp command from target cluster in with secured connection. Source: hadoop.server1 (ssh secured) Target: 
Here is a little puzzle. An admin works for a cash-strapped, popular web shop. At the datacenter she has a ten node cluster that is heavily used. It runs hot all day long and decommissioning a node with its background replicating of 12 disks worth of data messes up the work load she has on top of it and makes her clients very unhappy. Replicating the data of one node takes at least an hour. This
Hi All, Our Kafka cluster ran out of disk space yesterday. After we freed up the cluster disk space and adjusted the broker data retention policy, we noticed that the cluster partition was not balanced based on topic describe script came from Kafka 0.8.1.1 distribution. So, we tried to rebalance the partition using the kafka-reassign-partitions.sh. After sometime later, we ran out of disk
Hi, My architecture uses Jboss+ActiveMQ (in integrated mode) We have achieved HA (high availability) & HS (High Scalablity). A high level design looks like the below http://activemq.2283324.n4.nabble.com/ActiveMQ-Clustered-JBoss-and-JDBC-Master-Slave-td2348023.html#a2348028 Query is - when the primary node fails, the secondary node acquires a lock Is is possible to use Advisory messages
We are planning to move data from a 2 node cluster to a 3 node cluster. We are planning to copy the data from the two nodes (snapshot) to the new 2 nodes and hoping that Cassandra will sync it to the third node. Will this work ? are there any other commands to run after we are done migrating, like nodetool repair. Thanks all.
Hi guys, Any hint how to create a secured cluster using vagrant-puppet docker deployment? Possible someone has a sample? Thanks, Sergey
Hi All, We are using akka cluster 2.2.3 in our project. During a highly memory intensive operation cluster nodes start seeing each other as unreachable.  We perform a memory intensive operation across cluster which takes time as well as garbage collection occurs on each node. Is there any way to mark a node from unreachable state to reachable in order to make it cluster member again.   Can it
I have 2 nodes kafka cluster with default.replication.factor=2,is set in server.properties file. I removed one node-in removing that node,I killed Kafka process,removed all the kafka-logs and bundle from that node. Then I stopped my remaining running node in the cluster and started again(default.replication.factor is still set to 2 in this node server.properties file). I was expecting some