Skip to content

Commit 6e4c819

Browse files
committed
GH-2162: Fix Record Interceptor Javadocs
Resolves #2162
1 parent bee97d9 commit 6e4c819

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
@@ -323,19 +323,21 @@ public ContainerProperties getContainerProperties() {
323323

324324
/**
325325
* Set an interceptor to be called before calling the listener.
326-
* Does not apply to batch listeners.
326+
* Only used with record listeners.
327327
* @param recordInterceptor the interceptor.
328328
* @since 2.2.7
329+
* @see #setBatchInterceptor(BatchInterceptor)
329330
*/
330331
public void setRecordInterceptor(RecordInterceptor<K, V> recordInterceptor) {
331332
this.recordInterceptor = recordInterceptor;
332333
}
333334

334335
/**
335336
* Set a batch interceptor to be called before and after calling the listener.
336-
* Does not apply to batch listeners.
337+
* Only used with batch listeners.
337338
* @param batchInterceptor the interceptor.
338339
* @since 2.7
340+
* @see #setRecordInterceptor(RecordInterceptor)
339341
*/
340342
public void setBatchInterceptor(BatchInterceptor<K, V> batchInterceptor) {
341343
this.batchInterceptor = batchInterceptor;

0 commit comments

Comments
 (0)