@Configuration public static class KafkaSpecialProducerConsumerConfigExample.CustomKafkaBeans extends Object
Constructor and Description |
---|
CustomKafkaBeans() |
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.
|
@Bean public org.springframework.kafka.core.ProducerFactory<?,?> kafkaProducerFactory(KafkaProperties properties)
properties
- the kafka properties.@Bean public org.springframework.kafka.core.ConsumerFactory<?,?> kafkaConsumerFactory(KafkaProperties properties)
properties
- the kafka properties.Copyright © 2019 Pivotal Software, Inc.. All rights reserved.