从Java应用程序连接到Kerberos安全的HBase集群
，需要进行以下步骤：
- 配置Kerberos认证：首先，需要在HBase集群和Java应用程序所在的机器上配置Kerberos认证。这包括安装Kerberos客户端和配置Kerberos配置文件。具体的步骤可以参考腾讯云的Kerberos认证文档：Kerberos认证。
- 配置Java应用程序：在Java应用程序中，需要使用Kerberos认证来连接到HBase集群。可以使用HBase提供的Java API来进行连接。以下是一个示例代码：
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();在上述代码中，需要将ZK_QUORUM替换为HBase集群的ZooKeeper地址，ZK_PORT替换为ZooKeeper端口号，principal替换为Kerberos主体，keytab_path替换为Kerberos密钥表的路径。
- 进行HBase操作：一旦成功连接到HBase集群，就可以使用HBase提供的API进行数据操作。例如，可以使用
Table接口来进行表的读写操作。以下是一个示例代码：
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"));在上述代码中，需要将table_name替换为实际的表名，row_key替换为实际的行键，column_family和column替换为实际的列族和列名。
总结：通过以上步骤，就可以从Java应用程序连接到Kerberos安全的HBase集群，并进行数据操作。这样可以保证数据的安全性和权限控制。腾讯云提供了HBase服务，可以满足这一需求：腾讯云HBase。
相关·内容
我想通过 (python)连接到Kerberos 安全的 HBase数据库。该连接可用于另一个具有此设置的不安全集群：connection = happybase.Connection("host1.domain.de", port=9090)print(connection.tables())
现在，我想通过ZooKeepQu仲裁(比方说host2.doma
浏览 3提问于2017-08-09得票数 0
回答已采纳
我们有一个非Kerberized集群，它需要访问中的服务。
通过安装和配置Kerberos，创建SPN和UPN等？
浏览 1提问于2018-04-18得票数 1
我正在尝试使用以下代码连接到hbase： @Test public void onTrigger()抛出异常{ TestRunner runner = getTestRunner();;
//runner.setProperty("KerberosPrincipal", "myKerberosPrincipal&q
浏览 17提问于2019-04-22得票数 0
回答已采纳
我正在尝试使用Java从我的本地机器创建一个kerberos安全的Hadoop集群。", "kerberos");
hBaseConfig.set("hbase.master.kerberos.principal", <kerberos.hbase.principal>);UserGroupInformation
浏览 0提问于2015-02-07得票数 0
我有一个Java工具，可以将几行数据从一个HBase集群复制到另一个集群(称为ClusterA和ClusterB)。当两个集群都没有安全保护时，这种方法可以正常工作：Configuration注意: Utilities.makeHBaseConfig()方法从配置文件中加载ZooKeepQu仲裁设置。
现在，我正在尝试
浏览 5提问于2016-09-22得票数 0
我正试图在启用Kerberos的情况下将Spark应用程序连接到HBase。Spark版本为1.5.0，CDH为5.5.2，在纱线集群模式下执行。最可能的原因是凭据丢失或无效。考虑一下'kinit‘。现在，错误是：
java.io.IOException: usercomp@COMPANY.CORP从keytab登录失败krb5.usercomp.keytab: javax.security.auth.login.Logi
浏览 4提问于2016-05-04得票数 3
1回答
我有一个简单的任务:我想在一个HBase安全集群中读取Kerberos数据。到目前为止，我尝试了两种方法：
此外，似乎有一些HBase-火花连接器。但不知怎么的，我并没有找到它们作为Maven工件和/或它们需要一个固定的结果
浏览 2提问于2016-10-10得票数 2
4回答
嗨，我正在尝试为安全hbase编写一个java客户端。我还想从代码本身做kinit，因为我使用的是用户组信息类。有人能指出我哪里出了问题吗？ config.set("hbase.master.kerberos.principal", "hbase/gauravt-namenode.pbi.global.pvt@pbi.global.pvt
浏览 12提问于2014-05-09得票数 3
回答已采纳
1回答
我正在尝试使用JDBC通过spark纱线连接到安全的菲尼克斯，我可以在日志中看到，它正在成功地连接：这个问题只在我在纱线中运行时发生，但是当我在本地运行时，它使用的是相同的UserGroupInformation，并且能够连接到ClientService而没有任何问题。我在本地注意到，在一开始，UGI从我的</
浏览 0提问于2018-02-27得票数 2
面对启用了Kerberos的Hadoop群集的一个问题。 config.set("hbase.security.authenticati
浏览 0提问于2017-05-25得票数 0
2回答
我正在尝试用kerberos连接一个安全的hbase。它是部署到hdp3集群中的hbase。确切地说，我正在尝试从集群之外的主机访问java客户端。/meta-replyHeader:/hbase-安全/meta区域-服务器已完成:错误标头: 141,4 replyHeader: 141,365072222881,0请求：：‘
浏览 18提问于2020-05-10得票数 0
回答已采纳
在连接到使用菲尼克斯的安全hbase集群时，是否有人看到以下消息：似乎使用简单的身份验证连接到hbas
浏览 4提问于2015-08-27得票数 2
1回答
丝上火花+固定hbase
、、、、
我提交了一个工作给纱线(在spark 2.1.1 + kafka 0.10.2.1)，它连接到一个安全的hbase集群。然而，一旦我以纱线的形式(并将部署模式作为客户端)提交该作业，我就会看到以下错误消息-我正在遵循hortonworks关于向纱线集群提供有关HBase和key
浏览 14提问于2017-05-30得票数 6
1回答
实际上，我正试图在HDP集群(不是Kerberized)中建立一些自定义的安全设置。用例是hbase，kafka必须实现授权，但是使用kerberos。只有人为的错误是必须避免的，所以没有理由使用密码。都用爪哇语。
当然，没有身份验证就没有授权(这是Kerberos完成其工作的地方)。我能够在Kafka代理上实现授权(即使是在Kerberized集群上，代理也可以配置为从GSSAPI更改为PLAIN
浏览 1提问于2018-01-25得票数 2
回答已采纳
我们试图在Spark中执行一个简单的Scala代码来从Hbase中检索数据。Hadoop环境启用了Kerberos，我们已经确保执行kinit。调用Spark Shell的步骤：DRIVER_LIBRARY_PATH:193)
浏览 12提问于2016-02-11得票数 1
回答已采纳
由于Kerberos的安全性，我无法从浏览器访问WebHDFS。有人能帮我吗？HTTP错误401向该URL发出请求的.Net代码 http.Timeout
浏览 2提问于2015-11-23得票数 3
4回答
我正在尝试设置HBase来验证安全的HDFS和ZooKeeper。HMaster成功地使用ZooKeeper进行身份验证。但是，它仍然使用HDFS进行简单的身份验证。不知道我的配置中缺少了什么。/name> </property>
浏览 0提问于2014-01-24得票数 4
回答已采纳
我正在尝试从java应用程序连接到远程hbase。
远程hbase版本为2.1.0，例如我的本地hbase客户端.该代码在另一个cloudera环境中运行良好，唯一的区别是这个环境受到kerberos的保护，但我在日志中成功登录。在RpcServer日志中，我找到了“预期的HEADER=HBas，但收到了来自:61866的HEADER=\x00\x00\x01\x
浏览 1提问于2021-09-15得票数 4
回答已采纳
情况如下:我们有一个安全的(Kerberos) HBase集群。我有一个对象，它在启动时创建一个HTable实例，并将其保存下来。超过10个小时( Kerberos集群中的票证超时)之后，下一个扫描表的调用将得到如下结果：
16/12/01 18:16:24 WARN security.UserGroupInformation:PriviledgedActionException as:bigdata-app-an
浏览 4提问于2016-12-01得票数 2
回答已采纳
-2.5.0.jar:/usr/lib/hadoop/lib/aws-java-sdk-dynamodb-1.10.6.jar:/usr/lib/hadoop/lib/apacheds-kerberos-codec//apacheds-kerberos-codec-2.0.0-M15.jar:/usr/lib/hadoop-mapreduce/.<init>(Client
浏览 20提问于2017-07-16得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
实时音视频
即时通信 IM
对象存储活动推荐
腾讯云开发者
