Skip to content

Commit fbd416a

Browse files
committed
Merge branch '2.6.x' into 2.7.x
Closes gh-32773
2 parents 99f0a5e + e35de71 commit fbd416a

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

spring-boot-project/spring-boot-autoconfigure/src/main/java/org/springframework/boot/autoconfigure/kafka/KafkaAutoConfiguration.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -86,13 +86,13 @@ public KafkaAutoConfiguration(KafkaProperties properties) {
8686

8787
@Bean
8888
@ConditionalOnMissingBean(ProducerListener.class)
89-
public ProducerListener<Object, Object> kafkaProducerListener() {
89+
public LoggingProducerListener<Object, Object> kafkaProducerListener() {
9090
return new LoggingProducerListener<>();
9191
}
9292

9393
@Bean
9494
@ConditionalOnMissingBean(ConsumerFactory.class)
95-
public ConsumerFactory<?, ?> kafkaConsumerFactory(
95+
public DefaultKafkaConsumerFactory<?, ?> kafkaConsumerFactory(
9696
ObjectProvider<DefaultKafkaConsumerFactoryCustomizer> customizers) {
9797
DefaultKafkaConsumerFactory<Object, Object> factory = new DefaultKafkaConsumerFactory<>(
9898
this.properties.buildConsumerProperties());
@@ -102,7 +102,7 @@ public ProducerListener<Object, Object> kafkaProducerListener() {
102102

103103
@Bean
104104
@ConditionalOnMissingBean(ProducerFactory.class)
105-
public ProducerFactory<?, ?> kafkaProducerFactory(
105+
public DefaultKafkaProducerFactory<?, ?> kafkaProducerFactory(
106106
ObjectProvider<DefaultKafkaProducerFactoryCustomizer> customizers) {
107107
DefaultKafkaProducerFactory<?, ?> factory = new DefaultKafkaProducerFactory<>(
108108
this.properties.buildProducerProperties());

0 commit comments

Comments
 (0)