Class KafkaTokenUtil

Object
org.apache.spark.kafka010.KafkaTokenUtil

public class KafkaTokenUtil extends Object
  • Constructor Details

    • KafkaTokenUtil

      public KafkaTokenUtil()
  • Method Details

    • 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)
    • 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)
    • needTokenUpdate

      public static boolean needTokenUpdate(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)