Spring/spring-kafka
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Valid class names in KafkaListenerEndpointRegistry customization docs

Browse Source
This commit is contained in:
Artem Yakshin
2018-07-20 14:33:47 +03:00
committed by Artem Bilan
parent cadd61d3e5
commit c325ad110e
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
spring-kafka/src/main/java/org/springframework/kafka/annotation/EnableKafka.java
View File

@@ -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;
* }