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

KAFKA-12922: MirrorCheckpointTask should close topic filter (#10849) 

Reviewers: Mickael Maison <mickael.maison@gmail.com>

Co-authored-by: Daniel Urban <durban@cloudera.com>
This commit is contained in:
Viktor Somogyi-Vass 2021-06-10 18:17:42 +02:00 committed by GitHub
parent d496103864
commit 8a50a5204d
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 1 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorCheckpointTask.java
View File

@ -113,6 +113,7 @@ public class MirrorCheckpointTask extends SourceTask {
public void stop() {
long start = System.currentTimeMillis();
stopping = true;
Utils.closeQuietly(topicFilter, "topic filter");
Utils.closeQuietly(offsetSyncStore, "offset sync store");
Utils.closeQuietly(sourceAdminClient, "source admin client");
Utils.closeQuietly(targetAdminClient, "target admin client");