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 and Description
CustomKafkaBeans()

Method Summary

Modifier and Type	Method and Description
org.springframework.kafka.core.ConsumerFactory<?,?>	kafkaConsumerFactory(KafkaProperties properties) Customized ConsumerFactory bean.
org.springframework.kafka.core.ProducerFactory<?,?>	kafkaProducerFactory(KafkaProperties properties) Customized ProducerFactory bean.

Methods inherited from class java.lang.Object

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

Constructor Detail

CustomKafkaBeans

public CustomKafkaBeans()

Method Detail

kafkaProducerFactory

@Bean
public org.springframework.kafka.core.ProducerFactory<?,?> kafkaProducerFactory(KafkaProperties properties)

Customized ProducerFactory bean.

Parameters:

properties - the kafka properties.

Returns:

the bean.

kafkaConsumerFactory

@Bean
public org.springframework.kafka.core.ConsumerFactory<?,?> kafkaConsumerFactory(KafkaProperties properties)

Customized ConsumerFactory bean.

Parameters:

properties - the kafka properties.

Returns:

the bean.