root
/
kafka
mirror of https://github.com/apache/kafka.git
1
0
Fork 0
Code Issues Actions 3 Packages Projects Releases Wiki Activity

Update ApplicationEventProcessor.java

This commit is contained in:
Kirk True 2025-10-06 10:21:06 -07:00
parent fa784e5f25
commit 5be72105ba
1 changed files with 2 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
clients/src/main/java/org/apache/kafka/clients/consumer/internals/events/ApplicationEventProcessor.java
View File

@ -797,9 +797,8 @@ public class ApplicationEventProcessor implements EventProcessor<ApplicationEven
} }
/** /**
* If there's an error to report to the user, the current event will be completed with * If there's an error to report to the user, the current event will be completed and this method will
* {@link AsyncPollEvent.State#FAILED} and this method will return {@code true}. Otherwise, it will * return {@code true}. Otherwise, it will return {@code false}.
* return {@code false}.
*/ */
private boolean maybeCompleteAsyncPollEventExceptionally(AsyncPollEvent event, Throwable t) { private boolean maybeCompleteAsyncPollEventExceptionally(AsyncPollEvent event, Throwable t) {
if (t == null) if (t == null)