Skip to content

Commit ad4214d

Browse files
committed
GH-782: Fix GenericMessageListener Javadocs
Fixes #782
1 parent ddd4b46 commit ad4214d

File tree

1 file changed

+4
-8
lines changed

1 file changed

+4
-8
lines changed

spring-kafka/src/main/java/org/springframework/kafka/listener/GenericMessageListener.java

Lines changed: 4 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -49,10 +49,8 @@ default void onMessage(T data, Acknowledgment acknowledgment) {
4949
}
5050

5151
/**
52-
* Invoked with data from kafka and provides access to the {@link Consumer}
53-
* for operations such as pause/resume. Invoked with null data when a poll
54-
* returns no data (enabling resume). The default implementation throws
55-
* {@link UnsupportedOperationException}.
52+
* Invoked with data from kafka and provides access to the {@link Consumer}. The
53+
* default implementation throws {@link UnsupportedOperationException}.
5654
* @param data the data to be processed.
5755
* @param consumer the consumer.
5856
* @since 2.0
@@ -62,10 +60,8 @@ default void onMessage(T data, Consumer<?, ?> consumer) {
6260
}
6361

6462
/**
65-
* Invoked with data from kafka and provides access to the {@link Consumer}
66-
* for operations such as pause/resume. Invoked with null data when a poll
67-
* returns no data (enabling resume). The default implementation throws
68-
* {@link UnsupportedOperationException}.
63+
* Invoked with data from kafka and provides access to the {@link Consumer}. The
64+
* default implementation throws {@link UnsupportedOperationException}.
6965
* @param data the data to be processed.
7066
* @param acknowledgment the acknowledgment.
7167
* @param consumer the consumer.

0 commit comments

Comments
 (0)