root
/
kafka
mirror of https://github.com/apache/kafka.git
1
0
Fork 0
Code Issues Actions 2 Packages Projects Releases Wiki Activity

KAFKA-17723 Fix "this-escape" compiler warnings (MultiThreadedEventPr… (#19309) 

Cherry picked from commit 2353a7c508

Reviewers: Chia-Ping Tsai <chia7712@gmail.com>
This commit is contained in:
Stig Døssing 2025-04-06 18:52:17 +02:00 committed by GitHub
parent fe5802b304
commit fd4c90a7c9
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
2 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/DistributedHerder.java
View File

@ -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}, * @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 * after all services and resources owned by this herder are stopped
*/ */
@SuppressWarnings("this-escape")
public DistributedHerder(DistributedConfig config, public DistributedHerder(DistributedConfig config,
Time time, Time time,
Worker worker, Worker worker,
@ -272,6 +273,7 @@ public class DistributedHerder extends AbstractHerder implements Runnable {
} }
// visible for testing // visible for testing
@SuppressWarnings("this-escape")
DistributedHerder(DistributedConfig config, DistributedHerder(DistributedConfig config,
Worker worker, Worker worker,
String workerId, String workerId,

2
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/runtime/MultiThreadedEventProcessor.java
View File

@ -34,7 +34,7 @@ import java.util.stream.IntStream;
* A multithreaded {{@link CoordinatorEvent}} processor which uses a {{@link EventAccumulator}} * A multithreaded {{@link CoordinatorEvent}} processor which uses a {{@link EventAccumulator}}
* which guarantees that events sharing a partition key are not processed concurrently. * 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. * The poll timeout to wait for an event by the EventProcessorThread.