直接使用下面的旧代码: HBaseClient hbaseClient = new HBaseClient(zookeeper); 激活了kerberos需要: System.setProperty("java.security.auth.login.config
(String[] args) throws IOException { if (args.length > 0) { System.setProperty("java.security.auth.login.config
System.setProperty("java.security.krb5.conf", "/Volumes/Transcend/keytab/krb5.conf"); System.setProperty("java.security.auth.login.config...System.setProperty("java.security.krb5.conf", "/Volumes/Transcend/keytab/krb5.conf"); System.setProperty("java.security.auth.login.config
user_alice="alice-secret"; }; Modify the kafka-server-start.bat script to set the JVM parameter 'java.security.auth.login.config
4.在/conf文件夹下找到catalina.properties文件并编辑,在文件内容最后新增如下内容:java.security.auth.login.config=${catalina.base
有两种方法可以为Kafka客户端设置这些属性: 创建一个JAAS配置文件,并将Java系统属性java.security.auth.login.config指向它;要么 内联JAAS配置,设置Kafka
System.setProperty("java.security.krb5.conf", krb5conf); System.setProperty("java.security.auth.login.config
System.setProperty("ssun.security.jgss.debug", "true"); //Kerberos Debug模式 System.setProperty("java.security.auth.login.config
alice-secret"; }; Modify the kafka-server-start.bat/kafka-server-start.sh script to set the JVM parameter 'java.security.auth.login.config
false"); System.setProperty("sun.security.krb5.debug", "true"); System.setProperty("java.security.auth.login.config
System.setProperty("sun.security.krb5.debug", "true"); //Kerberos Debug模式 System.setProperty("java.security.auth.login.config
consumer.properties Java端的调用 首先需要拷贝一份linux中的/etc/krb5.conf 与 kafka_mac.keytab 到mac中 System.setProperty("java.security.auth.login.config
jaas 配置信息 System.setProperty(JaasUtils.JAVA_LOGIN_CONFIG_PARAM, kafkaProperties.getProperty("java.security.auth.login.config
hbase.region.principal"); String krb5Conf = parameterTool.get("krb5.conf.path"); System.setProperty("java.security.auth.login.config
public static void loginZK() { try { // 设置身份认证服务配置 System.setProperty("java.security.auth.login.config
kafka_client.keytab dy/kafka@CDH.AI.COM 在使用producer和consumer java接口时,要在代码main方法中,加入 System.setProperty(“java.security.auth.login.config
kafka.client.truststore.jks ## sasl路径,demo中有,请拷贝到自己的某个目录下,不能被打包到jar中 ## 这里假设您的目录为/home/admin,请记得修改为自己的实际目录 java.security.auth.login.config
领取专属 10元无门槛券
手把手带您无忧上云