KafkaTokenSparkConf (Spark 4.0.0-preview2 JavaDoc)

org.apache.spark.kafka010.KafkaTokenSparkConf

public class KafkaTokenSparkConf extends Object

Constructor Summary

Constructors

Constructor

Description

KafkaTokenSparkConf()
Method Summary

Modifier and Type

Method

Description

static String

CLUSTERS_CONFIG_PREFIX()

static String

DEFAULT_SASL_KERBEROS_SERVICE_NAME()

static String

DEFAULT_SASL_TOKEN_MECHANISM()

static String

DEFAULT_SECURITY_PROTOCOL_CONFIG()

static String

DEFAULT_TARGET_SERVERS_REGEX()

static scala.collection.immutable.Set<org.apache.spark.kafka010.KafkaTokenClusterConf>

getAllClusterConfigs(SparkConf sparkConf)

static org.apache.spark.kafka010.KafkaTokenClusterConf

getClusterConfig(SparkConf sparkConf, String identifier)

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

LogStringContext(scala.StringContext sc)

static org.slf4j.Logger

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

static void

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

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

Constructor Details
- KafkaTokenSparkConf
  
  public KafkaTokenSparkConf()
Method Details
- CLUSTERS_CONFIG_PREFIX
  
  public static String CLUSTERS_CONFIG_PREFIX()
- DEFAULT_TARGET_SERVERS_REGEX
  
  public static String DEFAULT_TARGET_SERVERS_REGEX()
- DEFAULT_SASL_KERBEROS_SERVICE_NAME
  
  public static String DEFAULT_SASL_KERBEROS_SERVICE_NAME()
- DEFAULT_SECURITY_PROTOCOL_CONFIG
  
  public static String DEFAULT_SECURITY_PROTOCOL_CONFIG()
- DEFAULT_SASL_TOKEN_MECHANISM
  
  public static String DEFAULT_SASL_TOKEN_MECHANISM()
- getClusterConfig
  
  public static org.apache.spark.kafka010.KafkaTokenClusterConf getClusterConfig(SparkConf sparkConf, String identifier)
- getAllClusterConfigs
  
  public static scala.collection.immutable.Set<org.apache.spark.kafka010.KafkaTokenClusterConf> getAllClusterConfigs(SparkConf sparkConf)
- 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)