File tree Expand file tree Collapse file tree 1 file changed +0
-9
lines changed
spring-kafka/src/main/java/org/springframework/kafka/annotation Expand file tree Collapse file tree 1 file changed +0
-9
lines changed Original file line number Diff line number Diff line change 137137 * specify an explicit default {@code KafkaListenerContainerFactory}
138138 *
139139 * <pre class="code">
140- * {
141- * @code
142140 * @Configuration
143141 * @EnableKafka
144142 * public class AppConfig implements KafkaListenerConfigurer {
157155 * return new MyService();
158156 * }
159157 * }
160- * }
161158 * </pre>
162159 *
163160 * It is also possible to specify a custom
171168 * validated against a custom {@code Validator}.
172169 *
173170 * <pre class="code">
174- * {
175- * @code
176171 * @Configuration
177172 * @EnableKafka
178173 * public class AppConfig implements KafkaListenerConfigurer {
200195 * return new MyService();
201196 * }
202197 * }
203- * }
204198 * </pre>
205199 *
206200 * Implementing {@code KafkaListenerConfigurer} also allows for fine-grained control over
207201 * endpoints registration via the {@code KafkaListenerEndpointRegistrar}. For example, the
208202 * following configures an extra endpoint:
209203 *
210204 * <pre class="code">
211- * {
212- * @code
213205 * @Configuration
214206 * @EnableKafka
215207 * public class AppConfig implements KafkaListenerConfigurer {
232224 *
233225 * // Kafka infrastructure setup
234226 * }
235- * }
236227 * </pre>
237228 *
238229 * Note that all beans implementing {@code KafkaListenerConfigurer} will be detected and
You can’t perform that action at this time.
0 commit comments