Package org.springframework.kafka.security.jaas

Class KafkaJaasLoginModuleInitializer

java.lang.Object

org.springframework.kafka.security.jaas.KafkaJaasLoginModuleInitializer

All Implemented Interfaces:

DisposableBean, SmartInitializingSingleton

public class KafkaJaasLoginModuleInitializer
extends Object
implements SmartInitializingSingleton, DisposableBean

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

Since:

1.3

Author:

Marius Bogoevici, Gary Russell, Edan Idzerda

Nested Class Summary

Nested Classes

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

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor	Description
KafkaJaasLoginModuleInitializer()

Method Summary

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

Methods inherited from class java.lang.Object

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

Field Details

KAFKA_CLIENT_CONTEXT_NAME

public static final String KAFKA_CLIENT_CONTEXT_NAME

The key for the kafka client configuration entry.

See Also:

• Constant Field Values

Constructor Details

KafkaJaasLoginModuleInitializer

public KafkaJaasLoginModuleInitializer()
                                throws IOException

Throws:

IOException

Method Details

setLoginModule

public void setLoginModule(String loginModule)

setControlFlag

public void setControlFlag(KafkaJaasLoginModuleInitializer.ControlFlag controlFlag)

setOptions

public void setOptions(Map<String,String> options)

afterSingletonsInstantiated

public void afterSingletonsInstantiated()

Specified by:

afterSingletonsInstantiated in interface SmartInitializingSingleton

destroy

public void destroy()

Specified by:

destroy in interface DisposableBean