Skip to content

Commit f96edc0

Browse files
committed
GH-2162: Fix Record Interceptor Javadocs
Resolves #2162
1 parent ea50386 commit f96edc0

File tree

1 file changed

+4
-2
lines changed

1 file changed

+4
-2
lines changed

spring-kafka/src/main/java/org/springframework/kafka/config/AbstractKafkaListenerContainerFactory.java

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -327,19 +327,21 @@ public ContainerProperties getContainerProperties() {
327327

328328
/**
329329
* Set an interceptor to be called before calling the listener.
330-
* Does not apply to batch listeners.
330+
* Only used with record listeners.
331331
* @param recordInterceptor the interceptor.
332332
* @since 2.2.7
333+
* @see #setBatchInterceptor(BatchInterceptor)
333334
*/
334335
public void setRecordInterceptor(RecordInterceptor<K, V> recordInterceptor) {
335336
this.recordInterceptor = recordInterceptor;
336337
}
337338

338339
/**
339340
* Set a batch interceptor to be called before and after calling the listener.
340-
* Does not apply to batch listeners.
341+
* Only used with batch listeners.
341342
* @param batchInterceptor the interceptor.
342343
* @since 2.7
344+
* @see #setRecordInterceptor(RecordInterceptor)
343345
*/
344346
public void setBatchInterceptor(BatchInterceptor<K, V> batchInterceptor) {
345347
this.batchInterceptor = batchInterceptor;

0 commit comments

Comments
 (0)