Removed Kafka identity (apache#48)

marcosdotps · Aug 30, 2017 · f33d6a3 · f33d6a3
1 parent 6033751
commit f33d6a3
Show file tree

Hide file tree

Showing 2 changed files with 0 additions and 5 deletions.
diff --git a/core/src/main/scala/org/apache/spark/security/ConfigSecurity.scala b/core/src/main/scala/org/apache/spark/security/ConfigSecurity.scala
@@ -114,10 +114,6 @@ object ConfigSecurity extends Logging{
             vaultToken,
             SSLConfig.sslTypeDataStore,
             options)
-          case "kafka" => SSLConfig.prepareEnvironment(vaultHost,
-            vaultToken,
-            SSLConfig.sslTypeKafkaStore,
-            options)
           case _ => Map[String, String]()
        }
         secretOptions ++ agg

diff --git a/core/src/main/scala/org/apache/spark/security/SSLConfig.scala b/core/src/main/scala/org/apache/spark/security/SSLConfig.scala
@@ -31,7 +31,6 @@ import org.apache.spark.internal.Logging
 object SSLConfig extends Logging {
 
   val sslTypeDataStore = "DATASTORE"
-  val sslTypeKafkaStore = "KAFKA"
 
   def prepareEnvironment(vaultHost: String,
                          vaultToken: String,