We are trying to run a simple Kafka code with new api to test Kerberos integration.
The code is present at https://pastebin.ubuntu.com/23356675/ We are using ticket based mechanism to test first and then we will use Keytabs java -Djava.security.krb5.conf=/etc/krb5.conf -Djava.security.auth.login.config=/tmp/commandline/kafka_client_jaas.conf -Dsun.security.krb5.debug=true -classpath /tmp/code-assembly-1.0.1-SNAPSHOT.jar com.FirstProducer factoryTestTopic The content of jaas file is KafkaClient { com.sun.security.auth.module.Krb5LoginModule required useTicketCache=true serviceName="kafka"; }; The exception we get is java.util.concurrent.ExecutionException: org.apache.kafka.common.errors.TimeoutException: Failed to update metadata after 60000 ms.