程序包 io.github.wooenrico.kafka.configuration

类 AutoKafkaConfiguration

java.lang.Object

io.github.wooenrico.kafka.configuration.AutoKafkaConfiguration

@ConditionalOnProperty(name="kafka.configuration.enabled",
                       matchIfMissing=false,
                       havingValue="true")
public class AutoKafkaConfiguration
extends Object

构造器概要

构造器

构造器	说明
AutoKafkaConfiguration()

方法概要

修饰符和类型	方法	说明
KafkaConsumerFactory	getKafkaConsumerFactory(KafkaProperties kafkaProperties)
KafkaProperties	kafkaProperties()
DefaultReactorKafkaSender	reactorKafkaSender(KafkaProperties kafkaProperties)

从类继承的方法 java.lang.Object

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

构造器详细资料

AutoKafkaConfiguration

public AutoKafkaConfiguration()

方法详细资料

kafkaProperties

@Bean
@ConfigurationProperties(prefix="kafka")
public KafkaProperties kafkaProperties()

getKafkaConsumerFactory

@Bean
@Primary
@ConditionalOnMissingBean(KafkaConsumerFactory.class)
public KafkaConsumerFactory getKafkaConsumerFactory(KafkaProperties kafkaProperties)

reactorKafkaSender

@Bean
@Primary
@ConditionalOnProperty(name="kafka.sender.primary.enabled",
                       matchIfMissing=false,
                       havingValue="true")
public DefaultReactorKafkaSender reactorKafkaSender(KafkaProperties kafkaProperties)