From c325ad110e732b164a048b1f38990ba3ef6a1ca4 Mon Sep 17 00:00:00 2001 From: Artem Yakshin Date: Fri, 20 Jul 2018 14:33:47 +0300 Subject: [PATCH] Valid class names in KafkaListenerEndpointRegistry customization docs --- .../org/springframework/kafka/annotation/EnableKafka.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/spring-kafka/src/main/java/org/springframework/kafka/annotation/EnableKafka.java b/spring-kafka/src/main/java/org/springframework/kafka/annotation/EnableKafka.java index 38fda751..01f70140 100644 --- a/spring-kafka/src/main/java/org/springframework/kafka/annotation/EnableKafka.java +++ b/spring-kafka/src/main/java/org/springframework/kafka/annotation/EnableKafka.java @@ -165,7 +165,7 @@ import org.springframework.context.annotation.Import; * {@link org.springframework.kafka.config.KafkaListenerEndpointRegistry * KafkaListenerEndpointRegistry} in case you need more control on the way the containers * are created and managed. The example below also demonstrates how to customize the - * {@code KafkaHandlerMethodFactory} to use with a custom + * {@link org.springframework.messaging.handler.annotation.support.DefaultMessageHandlerMethodFactory} to use with a custom * {@link org.springframework.validation.Validator Validator} so that payloads annotated * with {@link org.springframework.validation.annotation.Validated Validated} are first * validated against a custom {@code Validator}. @@ -188,8 +188,8 @@ import org.springframework.context.annotation.Import; * } * * @Bean - * public KafkaHandlerMethodFactory myMessageHandlerMethodFactory() { - * DefaultKafkaHandlerMethodFactory factory = new DefaultKafkaHandlerMethodFactory(); + * public MessageHandlerMethodFactory myMessageHandlerMethodFactory() { + * DefaultMessageHandlerMethodFactory factory = new DefaultMessageHandlerMethodFactory(); * factory.setValidator(new MyValidator()); * return factory; * }