MirrorCheckpointTask should close topic filter
Reviewers: Mickael Maison
@@ -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");
