[
https://issues.apache.org/jira/browse/KAFKA-15508?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15508:
------------------------------
Priority: Blocker (was: Minor)
> 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)
