org.apache.kafka.common.security.oauthbearer.secured

Class JaasOptionsUtils

java.lang.Object

org.apache.kafka.common.security.oauthbearer.secured.JaasOptionsUtils

public class JaasOptionsUtils
extends Object

JaasOptionsUtils is a utility class to perform logic for the JAAS options and is separated out here for easier, more direct testing.

Constructor Summary

Constructors

Constructor and Description
JaasOptionsUtils(Map<String,Object> options)

Method Summary

Modifier and Type	Method and Description
SSLSocketFactory	createSSLSocketFactory()
static Map<String,Object>	getOptions(String saslMechanism, List<AppConfigurationEntry> jaasConfigEntries)
Map<String,?>	getSslClientConfig()
boolean	shouldCreateSSLSocketFactory(URL url)
String	validateString(String name)
String	validateString(String name, boolean isRequired)

Methods inherited from class java.lang.Object

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

Constructor Detail

JaasOptionsUtils

public JaasOptionsUtils(Map<String,Object> options)

Method Detail

getOptions

public static Map<String,Object> getOptions(String saslMechanism,
                                            List<AppConfigurationEntry> jaasConfigEntries)

shouldCreateSSLSocketFactory

public boolean shouldCreateSSLSocketFactory(URL url)

getSslClientConfig

public Map<String,?> getSslClientConfig()

createSSLSocketFactory

public SSLSocketFactory createSSLSocketFactory()

validateString

public String validateString(String name)
                      throws ValidateException

Throws:

ValidateException

validateString

public String validateString(String name,
                             boolean isRequired)
                      throws ValidateException

Throws:

ValidateException