From 09f8cb57cfa437de57c69a8c9e3d7a4c3aaa63b2 Mon Sep 17 00:00:00 2001
From: Kirk True <kirk@kirktrue.pro>
Date: Mon, 15 Sep 2025 14:50:37 -0700
Subject: [PATCH] Add documentation for RequiresApplicationThreadExecution

Added a Javadoc comment to the RequiresApplicationThreadExecution interface to clarify its purpose and usage, specifically regarding the need to interrupt CompositePollEvent processing when requiresApplicationThread() returns true.
---
 .../internals/events/ApplicationEventProcessor.java        | 7 +++++--
 1 file changed, 5 insertions(+), 2 deletions(-)

diff --git a/clients/src/main/java/org/apache/kafka/clients/consumer/internals/events/ApplicationEventProcessor.java b/clients/src/main/java/org/apache/kafka/clients/consumer/internals/events/ApplicationEventProcessor.java
index 6881ff7c7dc..53c432e1968 100644
--- a/clients/src/main/java/org/apache/kafka/clients/consumer/internals/events/ApplicationEventProcessor.java
+++ b/clients/src/main/java/org/apache/kafka/clients/consumer/internals/events/ApplicationEventProcessor.java
@@ -914,10 +914,13 @@ public class ApplicationEventProcessor implements EventProcessor<ApplicationEven
         return requestManagers.offsetsRequestManager.updateFetchPositions(deadlineMs);
     }
 
+    /**
+     * This interface exists mostly to make the code more intuitive. When {@link #requiresApplicationThread()}
+     * returns true, the {@link CompositePollEvent} processing needs to be <em>interrupted</em> so that processing
+     * can return to the application thread.
+     */
     private interface RequiresApplicationThreadExecution {
 
         boolean requiresApplicationThread();
     }
-
-
 }