Greetings, I have setup my Kafka Connect with kerberized Kafka Cluster .(Say the KDC is "kafka-auth101.hadoop.local" and the realm "KAFKA.MYCOMPANY.COM")
Now I am trying to setup HDFS Sink with Kerberized Hadoop Cluster with a different KDC (Say the KDC is "hadoop-auth101.hadoop.local" and the realm " HADOOP.MYCOMPANY.COM" I have added both of these realms to the krb5.conf used by Kafka Connect. But during initialisation , HDFS Sink connector instance fails giving error : Any tips on this ? >>> KdcAccessibility: reset >>> KeyTabInputStream, readName(): HADOOP.MYCOMPANY.COM >>> KeyTabInputStream, readName(): hdfsuser >>> KeyTab: load() entry length: 85; type: 18 Looking for keys for: hdfsu...@hadoop.mycompany.com Found unsupported keytype (18) for hdfsu...@hadoop.mycompany.com [2019-03-19 07:21:12,330] INFO Couldn't start HdfsSinkConnector: (io.confluent.connect.hdfs.HdfsSinkTask) org.apache.kafka.connect.errors.ConnectException: java.io.IOException: Login failure for hdfsu...@hadoop.mycompany.com from keytab /etc/hadoop/keytab/stg.keytab: javax.security.auth.login.LoginException: Unable to obtain password from user at io.confluent.connect.hdfs.DataWriter.<init>(DataWriter.java:202) at io.confluent.connect.hdfs.HdfsSinkTask.start(HdfsSinkTask.java:76) at org.apache.kafka.connect.runtime.WorkerSinkTask.initializeAndStart(WorkerSinkTask.java:232) at org.apache.kafka.connect.runtime.WorkerSinkTask.execute(WorkerSinkTask.java:145) at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:146) at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:190) at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) at java.util.concurrent.FutureTask.run(FutureTask.java:266) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) at java.lang.Thread.run(Thread.java:745) Caused by: java.io.IOException: Login failure for hdfsu...@hadoop.mycompany.com from keytab /etc/hadoop/keytab/stg.keytab: javax.security.auth.login.LoginException: Unable to obtain password from user at org.apache.hadoop.security.UserGroupInformation.loginUserFromKeytab(UserGroupInformation.java:963) at io.confluent.connect.hdfs.DataWriter.<init>(DataWriter.java:127) ... 10 more Caused by: javax.security.auth.login.LoginException: Unable to obtain password from user
