[ https://issues.apache.org/jira/browse/KAFKA-15508?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17779175#comment-17779175 ]
Philip Nee commented on KAFKA-15508: ------------------------------------ This is not a blocker right? > Method always return the same value ApplicationEventProcessor.java > ------------------------------------------------------------------ > > Key: KAFKA-15508 > URL: https://issues.apache.org/jira/browse/KAFKA-15508 > Project: Kafka > Issue Type: Sub-task > Components: clients, consumer > Affects Versions: 3.5.1 > Reporter: Svyatoslav > Assignee: Kirk True > Priority: Blocker > Labels: consumer-threading-refactor, kip-848-e2e, kip-848-preview > > I'm not sure but i think that this is a bug, because method 'process' in > ApplicationEventProcessor.java always return true: > private {color:#FF0000}boolean process{color}(final PollApplicationEvent > event) { > Optional<RequestManager> commitRequestManger = > registry.get(RequestManager.Type.COMMIT); > if (!commitRequestManger.isPresent()) { > {color:#FF0000} return true{color}; > } > CommitRequestManager manager = (CommitRequestManager) > commitRequestManger.get(); > manager.updateAutoCommitTimer(event.pollTimeMs); > {color:#FF0000}return true{color}; > } -- This message was sent by Atlassian Jira (v8.20.10#820010)