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 c3045c44..a163bc25 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 @@ -137,8 +137,6 @@ import org.springframework.context.annotation.Import; * specify an explicit default {@code KafkaListenerContainerFactory} * *
- * {
- * @code
* @Configuration
* @EnableKafka
* public class AppConfig implements KafkaListenerConfigurer {
@@ -157,7 +155,6 @@ import org.springframework.context.annotation.Import;
* return new MyService();
* }
* }
- * }
*
*
* It is also possible to specify a custom
@@ -171,8 +168,6 @@ import org.springframework.context.annotation.Import;
* validated against a custom {@code Validator}.
*
*
- * {
- * @code
* @Configuration
* @EnableKafka
* public class AppConfig implements KafkaListenerConfigurer {
@@ -200,7 +195,6 @@ import org.springframework.context.annotation.Import;
* return new MyService();
* }
* }
- * }
*
*
* Implementing {@code KafkaListenerConfigurer} also allows for fine-grained control over
@@ -208,8 +202,6 @@ import org.springframework.context.annotation.Import;
* following configures an extra endpoint:
*
*
- * {
- * @code
* @Configuration
* @EnableKafka
* public class AppConfig implements KafkaListenerConfigurer {
@@ -232,7 +224,6 @@ import org.springframework.context.annotation.Import;
*
* // Kafka infrastructure setup
* }
- * }
*
*
* Note that all beans implementing {@code KafkaListenerConfigurer} will be detected and