从Java应用程序连接到Kerberos安全的HBase集群

Configuration conf = HBaseConfiguration.create();
conf.set("hbase.zookeeper.quorum", "ZK_QUORUM");
conf.set("hbase.zookeeper.property.clientPort", "ZK_PORT");
conf.set("hadoop.security.authentication", "kerberos");
UserGroupInformation.setConfiguration(conf);
UserGroupInformation.loginUserFromKeytab("principal", "keytab_path");

Connection connection = ConnectionFactory.createConnection(conf);
Admin admin = connection.getAdmin();

Table table = connection.getTable(TableName.valueOf("table_name"));
Put put = new Put(Bytes.toBytes("row_key"));
put.addColumn(Bytes.toBytes("column_family"), Bytes.toBytes("column"), Bytes.toBytes("value"));
table.put(put);

Get get = new Get(Bytes.toBytes("row_key"));
Result result = table.get(get);
byte[] value = result.getValue(Bytes.toBytes("column_family"), Bytes.toBytes("column"));