wang.bigbird.domain.framework.data.kafka

类 KafkaConfiguration

java.lang.Object

wang.bigbird.domain.framework.data.kafka.KafkaConfiguration

@Configuration
 @ComponentScan(basePackages="wang.bigbird.domain.framework.data.kafka")
public class KafkaConfiguration
extends Object

Kafka 配置

作者:

Bigbird

构造器概要

构造器

构造器和说明
KafkaConfiguration()

方法概要

限定符和类型	方法和说明
org.springframework.kafka.core.KafkaTemplate<String,byte[]>	bytesKafkaTemplate(org.springframework.kafka.core.ProducerFactory pf) KafkaTemplate（原生类型）
org.springframework.kafka.transaction.ChainedKafkaTransactionManager	chainedKafkaTransactionManager(org.springframework.jdbc.datasource.DataSourceTransactionManager transactionManager, org.springframework.kafka.transaction.KafkaTransactionManager<?,?> kafkaTransactionManager)
void	init()
org.springframework.kafka.core.ProducerFactory	kafkaProducerFactory(KafkaProducerProperties kafkaProducerProperties, KafkaConsumerProperties kafkaConsumerProperties, org.springframework.boot.autoconfigure.kafka.KafkaProperties springKafkaProperties) 生产者工厂
org.springframework.kafka.core.KafkaTemplate<String,Object>	objectKafkaTemplate(org.springframework.kafka.core.ProducerFactory pf) KafkaTemplate（json序列化方式）

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

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

构造器详细资料

KafkaConfiguration

public KafkaConfiguration()

方法详细资料

init

@PostConstruct
public void init()

kafkaProducerFactory

@Bean
 @Primary
 @Conditional(value=ProducerCondition.class)
public org.springframework.kafka.core.ProducerFactory kafkaProducerFactory(KafkaProducerProperties kafkaProducerProperties,
                                                                                                                                           KafkaConsumerProperties kafkaConsumerProperties,
                                                                                                                                           org.springframework.boot.autoconfigure.kafka.KafkaProperties springKafkaProperties)

生产者工厂

chainedKafkaTransactionManager

@Bean
 @Conditional(value=TransactionCondition.class)
 @ConditionalOnBean(value=org.springframework.jdbc.datasource.DataSourceTransactionManager.class)
public org.springframework.kafka.transaction.ChainedKafkaTransactionManager chainedKafkaTransactionManager(org.springframework.jdbc.datasource.DataSourceTransactionManager transactionManager,
                                                                                                                                                                                                                                                                      org.springframework.kafka.transaction.KafkaTransactionManager<?,?> kafkaTransactionManager)

objectKafkaTemplate

@Bean(name="objectKafkaTemplate")
 @Conditional(value=ProducerCondition.class)
public org.springframework.kafka.core.KafkaTemplate<String,Object> objectKafkaTemplate(org.springframework.kafka.core.ProducerFactory pf)

KafkaTemplate（json序列化方式）

bytesKafkaTemplate

@Bean(name="bytesKafkaTemplate")
 @Conditional(value=ProducerCondition.class)
public org.springframework.kafka.core.KafkaTemplate<String,byte[]> bytesKafkaTemplate(org.springframework.kafka.core.ProducerFactory pf)

KafkaTemplate（原生类型）