org.springframework.kafka.security.jaas

Class KafkaJaasLoginModuleInitializer

java.lang.Object

org.springframework.kafka.security.jaas.KafkaJaasLoginModuleInitializer

All Implemented Interfaces:

org.springframework.beans.factory.DisposableBean, org.springframework.beans.factory.SmartInitializingSingleton

public class KafkaJaasLoginModuleInitializer
extends java.lang.Object
implements org.springframework.beans.factory.SmartInitializingSingleton, org.springframework.beans.factory.DisposableBean

Contains properties for setting up an AppConfigurationEntry that can be used for the Kafka client.

Since:

1.3

Author:

Marius Bogoevici, Gary Russell

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	KafkaJaasLoginModuleInitializer.ControlFlag Control flag values for login configuration.

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	KAFKA_CLIENT_CONTEXT_NAME The key for the kafka client configuration entry.

Constructor Summary

Constructors

Constructor and Description
KafkaJaasLoginModuleInitializer()

Method Summary

Modifier and Type	Method and Description
void	afterSingletonsInstantiated()
void	destroy()
void	setControlFlag(KafkaJaasLoginModuleInitializer.ControlFlag controlFlag)
void	setLoginModule(java.lang.String loginModule)
void	setOptions(java.util.Map<java.lang.String,java.lang.String> options)

Methods inherited from class java.lang.Object

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

Field Detail

KAFKA_CLIENT_CONTEXT_NAME

public static final java.lang.String KAFKA_CLIENT_CONTEXT_NAME

The key for the kafka client configuration entry.

See Also:

Constant Field Values

Constructor Detail

KafkaJaasLoginModuleInitializer

public KafkaJaasLoginModuleInitializer()
                                throws java.io.IOException

Throws:

java.io.IOException

Method Detail

setLoginModule

public void setLoginModule(java.lang.String loginModule)

setControlFlag

public void setControlFlag(KafkaJaasLoginModuleInitializer.ControlFlag controlFlag)

setOptions

public void setOptions(java.util.Map<java.lang.String,java.lang.String> options)

afterSingletonsInstantiated

public void afterSingletonsInstantiated()

Specified by:

afterSingletonsInstantiated in interface org.springframework.beans.factory.SmartInitializingSingleton

destroy

public void destroy()
             throws java.lang.Exception

Specified by:

destroy in interface org.springframework.beans.factory.DisposableBean

Throws:

java.lang.Exception