Re: Consumer - Failed to find leader

2016-01-20 Thread prabhu v
Hi Harsh/Ismael, Any suggestions or inputs for the above issue? When i run the producer client, I still get this error ./kafka-console-producer.sh --broker-list hostname:9094 --topic topic3 *[2016-01-05 10:16:20,272] ERROR Error when sending message to topic test with key: null, value: 5 bytes

Re: Consumer - Failed to find leader

2016-01-05 Thread prabhu v
Hi Harsha, This is my Kafka_server_jaas.config file. This is passed as JVM param to the Kafka broker while start up. = KafkaServer { com.sun.security.auth.module.Krb5LoginModule required useKeyTab=true storeKey=true serviceName="kafka" keyTab="/etc/securi

Re: Consumer - Failed to find leader

2016-01-04 Thread Ismael Juma
Prabhu, were you able to get this to work in the end? Ismael

Re: Consumer - Failed to find leader

2015-12-30 Thread Harsha
can you add your jass file details. Your jaas file might have useTicketCache=true and storeKey=true as well example of KafkaServer jass file KafkaServer { com.sun.security.auth.module.Krb5LoginModule required useKeyTab=true storeKey=true serviceName="kafka" keyTab="/vagrant/keytabs/kafka1.key

Re: Consumer - Failed to find leader

2015-12-30 Thread prabhu v
Hi Harsha, I have used the Fully qualified domain name. Just for security concerns, Before sending this mail,i have replaced our FQDN hostname to localhost. yes, i have tried KINIT and I am able to view the tickets using klist command as well. Thanks, Prabhu On Wed, Dec 30, 2015 at 11:27 AM, Ha

Re: Consumer - Failed to find leader

2015-12-29 Thread Harsha
Prabhu, When using SASL/kerberos always make sure you give FQDN of the hostname . In your command you are using --zookeeper localhost:2181 and make sure you change that hostname. "avax.security.auth.login.LoginException: No key to store Will continue > connection

Re: Consumer - Failed to find leader

2015-12-28 Thread prabhu v
Thanks for the input Ismael. I will try and let you know. Also need your valuable inputs for the below issue:) i am not able to run kafka-topics.sh(0.9.0.0 version) [root@localhost bin]# ./kafka-topics.sh --list --zookeeper localhost:2181 [2015-12-28 12:41:32,589] WARN SASL configuration failed

Re: Consumer - Failed to find leader

2015-12-28 Thread Ismael Juma
Hi Prabhu, kafka-console-consumer.sh uses the old consumer by default, but only the new consumer supports security. Use --new-consumer to change this. Hope this helps. Ismael On 28 Dec 2015 05:48, "prabhu v" wrote: > Hi Experts, > > I am getting the below error when running the consumer > "kaf

Consumer - Failed to find leader

2015-12-27 Thread prabhu v
Hi Experts, I am getting the below error when running the consumer "kafka-console-consumer.sh" . I am using the new version 0.9.0.1. Topic name: test [2015-12-28 06:13:34,409] WARN [console-consumer-61657_localhost-1451283204993-5512891d-leader-finder-thread], Failed to find leader for Set([tes