Package org.springframework.boot.kafka
Class KafkaSpecialProducerConsumerConfigExample.CustomKafkaBeans
- java.lang.Object
- org.springframework.boot.kafka.KafkaSpecialProducerConsumerConfigExample.CustomKafkaBeans
- Enclosing class:
- KafkaSpecialProducerConsumerConfigExample
@Configuration public static class KafkaSpecialProducerConsumerConfigExample.CustomKafkaBeans extends Object
Constructor Summary
Constructors Constructor Description CustomKafkaBeans()
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description org.springframework.kafka.core.ConsumerFactory<?,?>kafkaConsumerFactory(org.springframework.boot.autoconfigure.kafka.KafkaProperties properties)Customized ConsumerFactory bean.org.springframework.kafka.core.ProducerFactory<?,?>kafkaProducerFactory(org.springframework.boot.autoconfigure.kafka.KafkaProperties properties)Customized ProducerFactory bean.
Constructor Detail
CustomKafkaBeans
public CustomKafkaBeans()
Method Detail
kafkaProducerFactory
@Bean public org.springframework.kafka.core.ProducerFactory<?,?> kafkaProducerFactory(org.springframework.boot.autoconfigure.kafka.KafkaProperties properties)
Customized ProducerFactory bean.- Parameters:
properties- the kafka properties.- Returns:
- the bean.
kafkaConsumerFactory
@Bean public org.springframework.kafka.core.ConsumerFactory<?,?> kafkaConsumerFactory(org.springframework.boot.autoconfigure.kafka.KafkaProperties properties)
Customized ConsumerFactory bean.- Parameters:
properties- the kafka properties.- Returns:
- the bean.