File tree 1 file changed +4
-2
lines changed
spring-kafka/src/main/java/org/springframework/kafka/config
1 file changed +4
-2
lines changed Original file line number Diff line number Diff line change @@ -304,19 +304,21 @@ public ContainerProperties getContainerProperties() {
304
304
305
305
/**
306
306
* Set an interceptor to be called before calling the listener.
307
- * Does not apply to batch listeners.
307
+ * Only used with record listeners.
308
308
* @param recordInterceptor the interceptor.
309
309
* @since 2.2.7
310
+ * @see #setBatchInterceptor(BatchInterceptor)
310
311
*/
311
312
public void setRecordInterceptor (RecordInterceptor <K , V > recordInterceptor ) {
312
313
this .recordInterceptor = recordInterceptor ;
313
314
}
314
315
315
316
/**
316
317
* Set a batch interceptor to be called before and after calling the listener.
317
- * Does not apply to batch listeners.
318
+ * Only used with batch listeners.
318
319
* @param batchInterceptor the interceptor.
319
320
* @since 2.7
321
+ * @see #setRecordInterceptor(RecordInterceptor)
320
322
*/
321
323
public void setBatchInterceptor (BatchInterceptor <K , V > batchInterceptor ) {
322
324
this .batchInterceptor = batchInterceptor ;
You can’t perform that action at this time.
0 commit comments