@Configuration @ConditionalOnMissingBean(value=org.springframework.cloud.stream.binder.Binder.class) @Import(value={org.springframework.cloud.stream.config.codec.kryo.KryoCodecAutoConfiguration.class,org.springframework.boot.autoconfigure.context.PropertyPlaceholderAutoConfiguration.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
Modifier and Type | Class and Description |
---|---|
static class |
KafkaBinderConfiguration.JaasConfigurationProperties |
Modifier and Type | Field and Description |
---|---|
protected static org.apache.commons.logging.Log |
logger |
Constructor and Description |
---|
KafkaBinderConfiguration() |
Modifier and Type | Method and Description |
---|---|
org.springframework.kafka.security.jaas.KafkaJaasLoginModuleInitializer |
jaasInitializer() |
AdminUtilsOperation |
kafka09AdminUtilsOperation() |
AdminUtilsOperation |
kafka10AdminUtilsOperation() |
org.springframework.boot.actuate.endpoint.PublicMetrics |
kafkaBinderMetrics(KafkaMessageChannelBinder kafkaMessageChannelBinder) |
@Bean public org.springframework.boot.actuate.endpoint.PublicMetrics kafkaBinderMetrics(KafkaMessageChannelBinder kafkaMessageChannelBinder)
@Bean(name="adminUtilsOperation") @Conditional(value=org.springframework.cloud.stream.binder.kafka.config.KafkaBinderConfiguration.Kafka09Present.class) @ConditionalOnClass(name="kafka.admin.AdminUtils") public AdminUtilsOperation kafka09AdminUtilsOperation()
@Bean(name="adminUtilsOperation") @Conditional(value=org.springframework.cloud.stream.binder.kafka.config.KafkaBinderConfiguration.Kafka1xPresent.class) @ConditionalOnClass(name="kafka.admin.AdminUtils") public AdminUtilsOperation kafka10AdminUtilsOperation()
@Bean public org.springframework.kafka.security.jaas.KafkaJaasLoginModuleInitializer jaasInitializer() throws IOException
IOException
Copyright © 2017 Pivotal Software, Inc.. All rights reserved.