[KAFKA-17723] Fix "this-escape" compiler warnings (MultiThreadedEventProcessor and DistributedHerder) for JDK 23

• Type: Sub-task
• Status: Resolved
• Priority: Minor
• Resolution: Fixed
• Fix Version/s: 4.0.0
• Assignee: Anshul Goyal
• Reporter: Chia-Ping Tsai
• Created: 08/Oct/24 12:03
• Updated: 11/Oct/24 13:28
• Resolved: 11/Oct/24 13:28

Description

> Task :coordinator-common:compileJava FAILED
/root/kafka/coordinator-common/src/main/java/org/apache/kafka/coordinator/common/runtime/MultiThreadedEventProcessor.java:107: warning: [this-escape] possible 'this' escape before subclass is fully initialized
        this.threads = IntStream.range(0, numThreads).mapToObj(threadId ->
                                                               ^
error: warnings found and -Werror specified
 

> Task :connect:runtime:compileJava
/root/kafka/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/DistributedHerder.java:269: warning: [this-escape] possible 'this' escape before subclass is fully initialized
        this(config, worker, worker.workerId(), kafkaClusterId, statusBackingStore, configBackingStore, null, restUrl, restClient, worker.metrics(),
            ^
/root/kafka/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/DistributedHerder.java:318: warning: [this-escape] previous possible 'this' escape happens here via invocation
                              new RebalanceListener(time), time, clientId, logContext);
 

Issue Links

• links to: GitHub Pull Request #17417