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 (MultiThreadedEventProcessor and DistributedHerder) for JDK 23 (#17417) 

Reviewers: Chia-Ping Tsai <chia7712@gmail.com>
This commit is contained in:
Anshul Goyal 2024-10-11 18:58:27 +05:30 committed by GitHub
parent b03fe66cfe
commit 2353a7c508
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},
* 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,

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

@ -33,7 +33,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.