kerberos+druid+phoenix

认证kerberos

public static void initKerberosEnv(Configuration conf, String principalName, String keytabPath, String krb5ConfPath, String loginConfigPath) throws Exception {System.setProperty("java.security.krb5.conf", krb5ConfPath);System.setProperty("java.security.auth.login.config", loginConfigPath);conf.set("hadoop.security.authentication", "Kerberos");// linux 环境会默认读取/etc/krb5.conf文件，win不指定会默认读取C:/Windows/krb5.iniUserGroupInformation.setConfiguration(conf);UserGroupInformation.loginUserFromKeytab(principalName, keytabPath);}

druid+kerberos+phoenix

@Bean(name = "hbaseDataSource", initMethod = "init", destroyMethod = "close")public DruidDataSource getHbaseDataSource() throws Exception {// 连接hadoop环境，进行 Kerberos认证org.apache.hadoop.conf.Configuration conf = HBaseConfiguration.create();KerberosInitor.initKerberosEnv(conf, hbasePrincipalName, hbaseKeytabPath, krb5ConfPath, loginConfigPath);//加载phoenix的配置Properties properties = new Properties();properties.setProperty("phoenix.schema.mapSystemTablesToNamespace", "true");properties.setProperty("phoenix.schema.isNamespaceMappingEnabled", "true");properties.setProperty("hbase.zookeeper.quorum", zookeeperQuorum);properties.setProperty("hbase.master.kerberos.principal", otherPrincipalName);properties.setProperty("hbase.regionserver.kerberos.principal", otherPrincipalName);properties.setProperty("phoenix.queryserver.kerberos.principal", otherPrincipalName);properties.setProperty("hbase.security.authentication", "kerberos");properties.setProperty("hadoop.security.authentication", "kerberos");properties.setProperty("zookeeper.znode.parent", "/hbase");DruidDataSource datasource = new DruidDataSource();datasource.setConnectProperties(properties);datasource.setUrl(hbaseUrl);datasource.setDriverClassName(hbaseDiverClassName);//configurationdatasource.setInitialSize(initialSize);datasource.setMinIdle(minIdle);datasource.setMaxActive(maxActive);datasource.setMaxWait(maxWait);datasource.setMinEvictableIdleTimeMillis(minEvictableIdleTimeMillis);datasource.setValidationQuery(validationQuery);datasource.setTestWhileIdle(testWhileIdle);datasource.setTestOnBorrow(testOnBorrow);datasource.setTestOnReturn(testOnReturn);datasource.setPoolPreparedStatements(poolPreparedStatements);datasource.setMaxPoolPreparedStatementPerConnectionSize(maxPoolPreparedStatementPerConnectionSize);return datasource;}

kerberos+druid+phoenix相关推荐

phoenix kerberos 连接配置
1. 官网资料 Use JDBC to get a connection to an HBase cluster like this: Connection conn = DriverManager. ...
SQL数据分析概览——Hive、Impala、Spark SQL、Drill、HAWQ 以及Presto+druid
转自infoQ! 根据 O'Reilly 2016年数据科学薪资调查显示,SQL 是数据科学领域使用最广泛的语言.大部分项目都需要一些SQL 操作,甚至有一些只需要SQL. 本文涵盖了6个开源领导者: ...
phoenix+hbase+Spark整合，Spark处理数据操作phoenix入hbase，Spring Cloud整合phoenix
1 版本要求 Spark版本:spark-2.3.0-bin-hadoop2.7 Phoenix版本:apache-phoenix-4.14.1-HBase-1.4-bin HBASE版本:hbase ...
Phoenix连接安全模式下的HBase集群
Phoenix连接安全模式下的HBase集群 HBase集群开启安全模式(即启用kerberos认证)之后,用户无论是用HBase shell还是Phoenix去连接HBase都先需要通过kerber ...
phoenix hbase java_java jdbc访问hbase phoenix
上面直接介绍了druid访问hbase phoenix的案例hbase Phoenix整合mybatis DruidDataSource 这里还是贴一下jdbc直接访问的方式.public stati ...
Kerberos Hbase Api 操作
初始化连接加载配置参数,这里只创建连接,具体操作hbase的api没有变化 static { try{ Configuration conf = HBaseConfiguration.create() ...
Hbase+Phoenix+Mybatis+Springboot整合查询数据
Phoenix Query Server提供了一种与Phoenix和HBase交互的替代方法.很快,这将允许从JVM以外的环境进行访问. 在4.x和5.0版本中,查询服务器及其JDBC客户端是标准Ph ...
【Druid】（八）Apache Druid 核心插件 Kafka Indexing Service SLS Indexing Service
文章目录一.前言二.与 Kafka 集群交互三.使用 Apache Druid Kafka Indexing Service 实时消费 Kafka 数据四.关于 SLS Indexing Se ...
kylin调优，项目中错误总结，知识点总结，kylin jdbc driver + 数据库连接池druid + Myba
首先给大家分享一个巨牛巨牛的人工智能教程,是我无意中发现的.教程不仅零基础,通俗易懂,而且非常风趣幽默,还时不时有内涵段子,像看小说一样,哈哈-我正在学习中,觉得太牛了,所以分享给大家!点这里可以跳转 ...

kerberos+druid+phoenix

kerberos+druid+phoenix相关推荐

最新文章

热门文章