hbase asynchbase 異步API 調用 ,如果需要kerberos認證,下面是必須的步驟,其實和opentsdb kerberos認證是一個道理。
這句很重要
KerberosClientAuthProvider authProvider = new KerberosClientAuthProvider(hbaseClient);
,是保持 ticket 24小時刷新的。
下面是代碼:
HBaseClient hbaseClient = new HBaseClient(zookeeper);
激活了kerberos需要:
System.setProperty("java.security.auth.login.config", "D:/kbs/jaas.conf");
System.setProperty("zookeeper.sasl.client", "false");
//下面行只在本地打開
System.setProperty("java.security.krb5.conf", "D:/kbs/krb5.conf");
org.hbase.async.Config asyncConfig = new org.hbase.async.Config();
asyncConfig.overrideConfig("hbase.zookeeper.quorum", zookeeper);
asyncConfig.overrideConfig("hbase.security.auth.enable", "true");
asyncConfig.overrideConfig("hbase.security.authentication", "kerberos");
asyncConfig.overrideConfig("hbase.sasl.clientconfig", "Client");
asyncConfig.overrideConfig("hbase.kerberos.regionserver.principal", "hbase/_HOST@HTSEC.COM");
HBaseClient hbaseClient = new HBaseClient(asyncConfig);
//認證
KerberosClientAuthProvider authProvider = new KerberosClientAuthProvider(hbaseClient);
<dependency>
<groupId>org.hbase</groupId>
<artifactId>asynchbase</artifactId>
<version>1.8.2</version>
</dependency>