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 7965257f774..619f670bd2c 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 @@ -736,7 +736,7 @@ public class ApplicationEventProcessor implements EventProcessor updatePositionsFuture = requestManagers.offsetsRequestManager.updateFetchPositions(event.deadlineMs()); context.trackCheckAndUpdatePositionsForTimeout(updatePositionsFuture, event.deadlineMs()); @@ -772,7 +772,7 @@ public class ApplicationEventProcessor implements EventProcessor {