org.springframework.cloud.stream.binder.kafka.config

Class KafkaBinderConfiguration

java.lang.Object

org.springframework.cloud.stream.binder.kafka.config.KafkaBinderConfiguration

@Configuration
 @ConditionalOnMissingBean(value=Binder.class)
 @Import(value={KryoCodecAutoConfiguration.class,org.springframework.boot.autoconfigure.context.PropertyPlaceholderAutoConfiguration.class,KafkaBinderConfiguration.KafkaPropertiesConfiguration.class})
 @EnableConfigurationProperties(value={org.springframework.cloud.stream.binder.kafka.properties.KafkaBinderConfigurationProperties.class,org.springframework.cloud.stream.binder.kafka.properties.KafkaExtendedBindingProperties.class})
public class KafkaBinderConfiguration
extends Object

Author:

David Turanski, Marius Bogoevici, Soby Chacko, Mark Fisher, Ilayaperumal Gopinathan

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	KafkaBinderConfiguration.JaasConfigurationProperties
static class	KafkaBinderConfiguration.KafkaPropertiesConfiguration

Field Summary

Fields

Modifier and Type	Field and Description
protected static org.apache.commons.logging.Log	logger

Constructor Summary

Constructors

Constructor and Description
KafkaBinderConfiguration()

Method Summary

Modifier and Type	Method and Description
org.springframework.context.ApplicationListener<?>	jaasInitializer()
org.springframework.cloud.stream.binder.kafka.admin.AdminUtilsOperation	kafka09AdminUtilsOperation()
org.springframework.cloud.stream.binder.kafka.admin.AdminUtilsOperation	kafka10AdminUtilsOperation()

Methods inherited from class java.lang.Object

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

Field Detail

logger

protected static final org.apache.commons.logging.Log logger

Constructor Detail

KafkaBinderConfiguration

public KafkaBinderConfiguration()

Method Detail

kafka09AdminUtilsOperation

@Bean(name="adminUtilsOperation")
 @Conditional(value=org.springframework.cloud.stream.binder.kafka.config.KafkaBinderConfiguration.Kafka09Present.class)
 @ConditionalOnClass(name="kafka.admin.AdminUtils")
public org.springframework.cloud.stream.binder.kafka.admin.AdminUtilsOperation kafka09AdminUtilsOperation()

kafka10AdminUtilsOperation

@Bean(name="adminUtilsOperation")
 @Conditional(value=org.springframework.cloud.stream.binder.kafka.config.KafkaBinderConfiguration.Kafka10Present.class)
 @ConditionalOnClass(name="kafka.admin.AdminUtils")
public org.springframework.cloud.stream.binder.kafka.admin.AdminUtilsOperation kafka10AdminUtilsOperation()

jaasInitializer

@Bean
public org.springframework.context.ApplicationListener<?> jaasInitializer()
                                                                         throws IOException

Throws:

IOException