org.apache.spark.kafka010

Class KafkaTokenSparkConf

Object

org.apache.spark.kafka010.KafkaTokenSparkConf

public class KafkaTokenSparkConf
extends Object

Constructor Summary

Constructors

Constructor and Description
KafkaTokenSparkConf()

Method Summary

Modifier and Type	Method and 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 void	org$apache$spark$internal$Logging$$log__$eq(org.slf4j.Logger x$1)
static org.slf4j.Logger	org$apache$spark$internal$Logging$$log_()

Methods inherited from class Object

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

Constructor Detail

KafkaTokenSparkConf

public KafkaTokenSparkConf()

Method Detail

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)