Created on 12-08-2017 09:10 PM - edited 08-17-2019 07:11 PM
Trying to pass JSON Cassandra data into Kafka
Continually getting this error: Failed while waiting for acks from Kafka
Attached in the photo are my current settings.
I am confident in all of my settings except for Client Name. What is the purpose of that settings and is there a default for it?
Created 12-09-2017 04:45 PM
What's your Kafka version?
From the properties I can see that you are using PutKafka which is legacy and used for Kafka 0.8.
If you are using Kafka 0.9/10/11 use PublishKafkaXXX instead
Created 12-11-2017 09:00 PM
Created 12-12-2017 07:06 AM
This is a timeout error. Which port are you using with PublishKafka_0_10? can you show your processor's configuration?
Created on 12-12-2017 03:35 PM - edited 08-17-2019 07:11 PM
Created 12-11-2017 08:33 PM
Created 12-12-2017 03:41 PM
You should use port 6667 instead of 2181. The new Kafka API doesn't use Zookeeper directly.
Can you test with this port and let me know ?
Created 12-12-2017 03:44 PM
@Abdelkrim Hadjidj Changed the port to 6667 after the FQDN and got the same error: .TimeoutException: Failed to update metadata after 5000 ms.: Failed to update metadata after 5000 ms.
Created 12-12-2017 04:56 PM
Have you installed Kafka with Ambari? if no, maybe the port is different in your case. Check in your configuration files. Also I ca see that set the Kerberos Service Name to Kafka. Is the Kafka Kerberised? if no, why you set the Kerberos Service Name?
Created 12-12-2017 06:07 PM
@Abdelkrim Hadjidj Kafka was installed with Amabari. I did not do the installing though. The service name was a possible fix I had seen, but it has since been removed.