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 137
137
* specify an explicit default {@code KafkaListenerContainerFactory}
138
138
*
139
139
* <pre class="code">
140
- * {
141
- * @code
142
140
* @Configuration
143
141
* @EnableKafka
144
142
* public class AppConfig implements KafkaListenerConfigurer {
157
155
* return new MyService();
158
156
* }
159
157
* }
160
- * }
161
158
* </pre>
162
159
*
163
160
* It is also possible to specify a custom
171
168
* validated against a custom {@code Validator}.
172
169
*
173
170
* <pre class="code">
174
- * {
175
- * @code
176
171
* @Configuration
177
172
* @EnableKafka
178
173
* public class AppConfig implements KafkaListenerConfigurer {
200
195
* return new MyService();
201
196
* }
202
197
* }
203
- * }
204
198
* </pre>
205
199
*
206
200
* Implementing {@code KafkaListenerConfigurer} also allows for fine-grained control over
207
201
* endpoints registration via the {@code KafkaListenerEndpointRegistrar}. For example, the
208
202
* following configures an extra endpoint:
209
203
*
210
204
* <pre class="code">
211
- * {
212
- * @code
213
205
* @Configuration
214
206
* @EnableKafka
215
207
* public class AppConfig implements KafkaListenerConfigurer {
232
224
*
233
225
* // Kafka infrastructure setup
234
226
* }
235
- * }
236
227
* </pre>
237
228
*
238
229
* Note that all beans implementing {@code KafkaListenerConfigurer} will be detected and
You can’t perform that action at this time.
0 commit comments