Use Threadlocal.remote to avoid leak on TimestampRouter
Reviewers: Guozhang Wang
@@ -91,7 +91,7 @@ public class TimestampRouter<R extends ConnectRecord<R>> implements Transformati
@Override
public void close() {
- timestampFormat = null;
+ timestampFormat.remove();
}
@Override
