Class KafkaTokenSparkConf

Object
org.apache.spark.kafka010.KafkaTokenSparkConf

public class KafkaTokenSparkConf extends Object
  • 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)