[jira] [Created] (ATLAS-4361) Hive Hook can't send notification

["ighack (Jira)" <ji...@apache.org>]

ighack created ATLAS-4361:
-----------------------------

             Summary: Hive Hook can't send notification
                 Key: ATLAS-4361
                 URL: https://issues.apache.org/jira/browse/ATLAS-4361
             Project: Atlas
          Issue Type: Task
          Components: hive-integration
    Affects Versions: 2.1.0
            Reporter: ighack


when I create a view

I get a error 

 

Caused by: javax.security.auth.login.LoginException: Could not login: the client is being asked for a password, but the Kafka client code does not currently support obtaining a password from the user. not available to garner authentication information from the user

 

but I make sure keytab and principal is OK

#Enable for Kerberized Kafka clusters
atlas.notification.kafka.service.principal=jztwk/hadoop@JOIN.COM
atlas.notification.kafka.keytab.location=/hadoop/app/jztwk.keytab
atlas.kafka.security.protocol=SASL_PLAINTEXT
atlas.kafka.sasl.kerberos.service.name=kafka

######### JAAS Configuration ########

atlas.jaas.KafkaClient.loginModuleName=com.sun.security.auth.module.Krb5LoginModule
atlas.jaas.KafkaClient.loginModuleControlFlag=required
atlas.jaas.KafkaClient.option.useKeyTab=true
atlas.jaas.KafkaClient.option.storeKey=true
atlas.jaas.KafkaClient.option.serviceName=kafka
atlas.jaas.KafkaClient.option.keyTab=/hadoop/app/jztwk.keytab
[atlas.jaas.KafkaClient.option.principal=jztwk/hadoop@JOIN.COM|mailto:atlas.jaas.KafkaClient.option.principal=jztwk/hadoop@JOIN.COM]

 

and I modify [KafkaNotification.java|https://sourcegraph.com/github.com/apache/atlas/-/blob/notification/src/main/java/org/apache/atlas/kafka/KafkaNotification.java] add a debug

LOG.debug("sasl.jaas.config is " + newJaasProperty);

 

I see  

sasl.jaas.config is  *com.sun.security.auth.module.Krb5LoginModule required keyTab="/hadoop/app/jztwk.keytab" storeKey=true useKeyTab=true principal="jztwk/hadoop@JOIN.COM" ;*

in log 

I use this config to my application.

that is OK.

 

Properties props = new Properties();
 props.put("bootstrap.servers", "bigdser1:9092,bigdser2:9092,bigdser3:9092,bigdser4:9092,bigdser5:9092");

System.setProperty("java.security.krb5.conf","D:/file/krb5.conf");

props.put("sasl.jaas.config","com.sun.security.auth.module.Krb5LoginModule required keyTab=\"D:/file/jztwk.keytab\" storeKey=true useKeyTab=true principal=\"jztwk/hadoop@JOIN.COM\" ;");
 props.put("security.protocol", "SASL_PLAINTEXT");
 props.put("sasl.kerberos.service.name", "kafka");

props.put("key.serializer", "org.apache.kafka.common.serialization.StringSerializer");
props.put("value.serializer", "org.apache.kafka.common.serialization.StringSerializer");
KafkaProducer<String,String> producer = new KafkaProducer<>(props);

 

so, I don't understand why



--
This message was sent by Atlassian Jira
(v8.3.4#803005)