@Configuration @ConditionalOnMissingBean(value=Binder.class) @Import(value=org.springframework.boot.autoconfigure.context.PropertyPlaceholderAutoConfiguration.class) @EnableConfigurationProperties(value=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() |
io.micrometer.core.instrument.binder.MeterBinder |
kafkaBinderMetrics(KafkaMessageChannelBinder kafkaMessageChannelBinder,
org.springframework.cloud.stream.binder.kafka.properties.KafkaBinderConfigurationProperties configurationProperties,
io.micrometer.core.instrument.MeterRegistry meterRegistry) |
@Bean public io.micrometer.core.instrument.binder.MeterBinder kafkaBinderMetrics(KafkaMessageChannelBinder kafkaMessageChannelBinder, org.springframework.cloud.stream.binder.kafka.properties.KafkaBinderConfigurationProperties configurationProperties, @Nullable io.micrometer.core.instrument.MeterRegistry meterRegistry)
@Bean public org.springframework.kafka.security.jaas.KafkaJaasLoginModuleInitializer jaasInitializer() throws IOException
IOException
Copyright © 2018 Pivotal Software, Inc.. All rights reserved.