(kafka) branch 3.9 updated: KAFKA-17723 Fix "this-escape" compiler warnings (MultiThreadedEventPr… (#19309)

[chia7712]

This is an automated email from the ASF dual-hosted git repository.

chia7712 pushed a commit to branch 3.9
in repository https://gitbox.apache.org/repos/asf/kafka.git


The following commit(s) were added to refs/heads/3.9 by this push:
     new fd4c90a7c9c KAFKA-17723 Fix "this-escape" compiler warnings 
(MultiThreadedEventPr… (#19309)
fd4c90a7c9c is described below

commit fd4c90a7c9c9eda8b15a3f907405d1118a76a7ed
Author: Stig Døssing <stigdoess...@gmail.com>
AuthorDate: Sun Apr 6 18:52:17 2025 +0200

    KAFKA-17723 Fix "this-escape" compiler warnings (MultiThreadedEventPr… 
(#19309)
    
    Cherry picked from commit 2353a7c5081b53402d5092afd255e2bdf7aa2d20
    
    Reviewers: Chia-Ping Tsai <chia7...@gmail.com>
---
 .../org/apache/kafka/connect/runtime/distributed/DistributedHerder.java | 2 ++
 .../kafka/coordinator/group/runtime/MultiThreadedEventProcessor.java    | 2 +-
 2 files changed, 3 insertions(+), 1 deletion(-)

diff --git 
a/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/DistributedHerder.java
 
b/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/DistributedHerder.java
index 174adea8cdd..d61b53ac72b 100644
--- 
a/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/DistributedHerder.java
+++ 
b/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/DistributedHerder.java
@@ -255,6 +255,7 @@ public class DistributedHerder extends AbstractHerder 
implements Runnable {
      * @param uponShutdown       any {@link AutoCloseable} objects that should 
be closed when this herder is {@link #stop() stopped},
      *                           after all services and resources owned by 
this herder are stopped
      */
+    @SuppressWarnings("this-escape")
     public DistributedHerder(DistributedConfig config,
                              Time time,
                              Worker worker,
@@ -272,6 +273,7 @@ public class DistributedHerder extends AbstractHerder 
implements Runnable {
     }
 
     // visible for testing
+    @SuppressWarnings("this-escape")
     DistributedHerder(DistributedConfig config,
                       Worker worker,
                       String workerId,
diff --git 
a/group-coordinator/src/main/java/org/apache/kafka/coordinator/group/runtime/MultiThreadedEventProcessor.java
 
b/group-coordinator/src/main/java/org/apache/kafka/coordinator/group/runtime/MultiThreadedEventProcessor.java
index fa1f734c1c7..599ccf834ce 100644
--- 
a/group-coordinator/src/main/java/org/apache/kafka/coordinator/group/runtime/MultiThreadedEventProcessor.java
+++ 
b/group-coordinator/src/main/java/org/apache/kafka/coordinator/group/runtime/MultiThreadedEventProcessor.java
@@ -34,7 +34,7 @@ import java.util.stream.IntStream;
  * A multithreaded {{@link CoordinatorEvent}} processor which uses a {{@link 
EventAccumulator}}
  * which guarantees that events sharing a partition key are not processed 
concurrently.
  */
-public class MultiThreadedEventProcessor implements CoordinatorEventProcessor {
+public final class MultiThreadedEventProcessor implements 
CoordinatorEventProcessor {
 
     /**
      * The poll timeout to wait for an event by the EventProcessorThread.