org.apache.spark.kafka010

Class KafkaTokenUtil

Object

org.apache.spark.kafka010.KafkaTokenUtil

public class KafkaTokenUtil
extends Object

Constructor Summary

Constructors

Constructor and Description
KafkaTokenUtil()

Method Summary

Modifier and Type	Method and Description
static scala.Option<org.apache.spark.kafka010.KafkaTokenClusterConf>	findMatchingTokenClusterConfig(SparkConf sparkConf, String bootStrapServers)
static String	getKeytabJaasParams(String keyTab, String principal, String kerberosServiceName)
static String	getKrb5LoginModuleName() Krb5LoginModule package vary in different JVMs.
static String	getTokenJaasParams(org.apache.spark.kafka010.KafkaTokenClusterConf clusterConf)
static void	initializeForcefully(boolean isInterpreter, boolean silent)
static boolean	isConnectorUsingCurrentToken(java.util.Map<String,Object> params, scala.Option<org.apache.spark.kafka010.KafkaTokenClusterConf> clusterConfig)
static boolean	isGlobalJaasConfigurationProvided()
static void	org$apache$spark$internal$Logging$$log__$eq(org.slf4j.Logger x$1)
static org.slf4j.Logger	org$apache$spark$internal$Logging$$log_()
static org.apache.hadoop.io.Text	TOKEN_KIND()

Methods inherited from class Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

KafkaTokenUtil

public KafkaTokenUtil()

Method Detail

TOKEN_KIND

public static org.apache.hadoop.io.Text TOKEN_KIND()

isGlobalJaasConfigurationProvided

public static boolean isGlobalJaasConfigurationProvided()

getKeytabJaasParams

public static String getKeytabJaasParams(String keyTab,
                                         String principal,
                                         String kerberosServiceName)

getKrb5LoginModuleName

public static String getKrb5LoginModuleName()

Krb5LoginModule package vary in different JVMs. Please see Hadoop UserGroupInformation for further details.

Returns:

(undocumented)

findMatchingTokenClusterConfig

public static scala.Option<org.apache.spark.kafka010.KafkaTokenClusterConf> findMatchingTokenClusterConfig(SparkConf sparkConf,
                                                                                                           String bootStrapServers)

getTokenJaasParams

public static String getTokenJaasParams(org.apache.spark.kafka010.KafkaTokenClusterConf clusterConf)

isConnectorUsingCurrentToken

public static boolean isConnectorUsingCurrentToken(java.util.Map<String,Object> params,
                                                   scala.Option<org.apache.spark.kafka010.KafkaTokenClusterConf> clusterConfig)

org$apache$spark$internal$Logging$$log_

public static org.slf4j.Logger org$apache$spark$internal$Logging$$log_()

org$apache$spark$internal$Logging$$log__$eq

public static void org$apache$spark$internal$Logging$$log__$eq(org.slf4j.Logger x$1)

initializeForcefully

public static void initializeForcefully(boolean isInterpreter,
                                        boolean silent)