@Configuration @ConditionalOnMissingBean(value=Binder.class) @Import(value=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() |
org.springframework.cloud.stream.binder.kafka.admin.AdminUtilsOperation |
kafka10AdminUtilsOperation() |
io.micrometer.core.instrument.binder.MeterBinder |
kafkaBinderMetrics(KafkaMessageChannelBinder kafkaMessageChannelBinder) |
@Bean public io.micrometer.core.instrument.binder.MeterBinder kafkaBinderMetrics(KafkaMessageChannelBinder kafkaMessageChannelBinder)
@Bean(name="adminUtilsOperation") @ConditionalOnClass(name="kafka.admin.AdminUtils") public org.springframework.cloud.stream.binder.kafka.admin.AdminUtilsOperation kafka10AdminUtilsOperation()
@Bean public org.springframework.kafka.security.jaas.KafkaJaasLoginModuleInitializer jaasInitializer() throws IOException
IOException
Copyright © 2017 Pivotal Software, Inc.. All rights reserved.