Details
-
Sub-task
-
Status: Resolved
-
Minor
-
Resolution: Fixed
-
3.5.1
Description
I'm not sure but i think that this is a bug, because method 'process' in ApplicationEventProcessor.java always return true:
private boolean process(final PollApplicationEvent event) {
Optional<RequestManager> commitRequestManger = registry.get(RequestManager.Type.COMMIT);
if (!commitRequestManger.isPresent()) {
return true;
}
CommitRequestManager manager = (CommitRequestManager) commitRequestManger.get();
manager.updateAutoCommitTimer(event.pollTimeMs);
return true;
}
Attachments
Issue Links
- is related to
-
KAFKA-14274 Introduce FetchRequestManager to integrate fetch into new consumer threading refactor
- Resolved