KafkaTokenUtil (Spark 4.0.0-preview2 JavaDoc)

org.apache.spark.kafka010.KafkaTokenUtil

public class KafkaTokenUtil extends Object

Constructor Summary

Constructors

Constructor

Description

KafkaTokenUtil()
Method Summary

Modifier and Type

Method

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

getTokenJaasParams(org.apache.spark.kafka010.KafkaTokenClusterConf clusterConf)

static boolean

isGlobalJaasConfigurationProvided()

static org.apache.spark.internal.Logging.LogStringContext

LogStringContext(scala.StringContext sc)

static boolean

needTokenUpdate(Map<String,Object> params, scala.Option<org.apache.spark.kafka010.KafkaTokenClusterConf> clusterConfig)

static org.slf4j.Logger

org$apache$spark$internal$Logging$$log_()

static void

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

static org.apache.hadoop.io.Text

TOKEN_KIND()

Methods inherited from class java.lang.Object
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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)
- LogStringContext
  
  public static org.apache.spark.internal.Logging.LogStringContext LogStringContext(scala.StringContext sc)