diff --git a/spring-boot-project/spring-boot-autoconfigure/src/main/java/org/springframework/boot/autoconfigure/kafka/KafkaAutoConfiguration.java b/spring-boot-project/spring-boot-autoconfigure/src/main/java/org/springframework/boot/autoconfigure/kafka/KafkaAutoConfiguration.java index 6a6e0183293f..d9efe18bdeb6 100644 --- a/spring-boot-project/spring-boot-autoconfigure/src/main/java/org/springframework/boot/autoconfigure/kafka/KafkaAutoConfiguration.java +++ b/spring-boot-project/spring-boot-autoconfigure/src/main/java/org/springframework/boot/autoconfigure/kafka/KafkaAutoConfiguration.java @@ -1,5 +1,5 @@ /* - * Copyright 2012-2020 the original author or authors. + * Copyright 2012-2022 the original author or authors. * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. @@ -75,13 +75,13 @@ public KafkaAutoConfiguration(KafkaProperties properties) { @Bean @ConditionalOnMissingBean(ProducerListener.class) - public ProducerListener kafkaProducerListener() { + public LoggingProducerListener kafkaProducerListener() { return new LoggingProducerListener<>(); } @Bean @ConditionalOnMissingBean(ConsumerFactory.class) - public ConsumerFactory kafkaConsumerFactory( + public DefaultKafkaConsumerFactory kafkaConsumerFactory( ObjectProvider customizers) { DefaultKafkaConsumerFactory factory = new DefaultKafkaConsumerFactory<>( this.properties.buildConsumerProperties()); @@ -91,7 +91,7 @@ public ProducerListener kafkaProducerListener() { @Bean @ConditionalOnMissingBean(ProducerFactory.class) - public ProducerFactory kafkaProducerFactory( + public DefaultKafkaProducerFactory kafkaProducerFactory( ObjectProvider customizers) { DefaultKafkaProducerFactory factory = new DefaultKafkaProducerFactory<>( this.properties.buildProducerProperties());