File tree Expand file tree Collapse file tree 2 files changed +7
-7
lines changed
spring-kafka/src/main/java/org/springframework/kafka/annotation Expand file tree Collapse file tree 2 files changed +7
-7
lines changed Original file line number Diff line number Diff line change 33
33
*
34
34
* @author Stephane Nicoll
35
35
* @author Gary Russell
36
+ * @author Artem Bilan
36
37
*
37
38
* @see KafkaListenerAnnotationBeanPostProcessor
38
39
* @see KafkaListenerEndpointRegistry
39
40
* @see EnableKafka
40
41
*/
41
- @ Configuration
42
+ @ Configuration ( proxyBeanMethods = false )
42
43
public class KafkaBootstrapConfiguration {
43
44
44
- @ SuppressWarnings ("rawtypes" )
45
45
@ Bean (name = KafkaListenerConfigUtils .KAFKA_LISTENER_ANNOTATION_PROCESSOR_BEAN_NAME )
46
46
@ Role (BeanDefinition .ROLE_INFRASTRUCTURE )
47
- public KafkaListenerAnnotationBeanPostProcessor kafkaListenerAnnotationProcessor () {
48
- return new KafkaListenerAnnotationBeanPostProcessor ();
47
+ public KafkaListenerAnnotationBeanPostProcessor <?, ?> kafkaListenerAnnotationProcessor () {
48
+ return new KafkaListenerAnnotationBeanPostProcessor <> ();
49
49
}
50
50
51
51
@ Bean (name = KafkaListenerConfigUtils .KAFKA_LISTENER_ENDPOINT_REGISTRY_BEAN_NAME )
Original file line number Diff line number Diff line change 39
39
*
40
40
* @since 1.1.4
41
41
*/
42
- @ Configuration
42
+ @ Configuration ( proxyBeanMethods = false )
43
43
public class KafkaStreamsDefaultConfiguration {
44
44
45
45
/**
@@ -56,8 +56,8 @@ public class KafkaStreamsDefaultConfiguration {
56
56
@ Bean (name = DEFAULT_STREAMS_BUILDER_BEAN_NAME )
57
57
public StreamsBuilderFactoryBean defaultKafkaStreamsBuilder (
58
58
@ Qualifier (DEFAULT_STREAMS_CONFIG_BEAN_NAME )
59
- ObjectProvider <KafkaStreamsConfiguration > streamsConfigProvider ,
60
- ObjectProvider <StreamsBuilderFactoryBeanCustomizer > customizerProvider ) {
59
+ ObjectProvider <KafkaStreamsConfiguration > streamsConfigProvider ,
60
+ ObjectProvider <StreamsBuilderFactoryBeanCustomizer > customizerProvider ) {
61
61
62
62
KafkaStreamsConfiguration streamsConfig = streamsConfigProvider .getIfAvailable ();
63
63
if (streamsConfig != null ) {
You can’t perform that action at this time.
0 commit comments