[kafka] branch trunk updated: KAFKA-10502: Use Threadlocal.remote to avoid leak on TimestampRouter (#9304)

[guozhang]

This is an automated email from the ASF dual-hosted git repository.

guozhang pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git


The following commit(s) were added to refs/heads/trunk by this push:
     new 18f7083  KAFKA-10502: Use Threadlocal.remote to avoid leak on 
TimestampRouter (#9304)
18f7083 is described below

commit 18f70835a39381967b4d0d57effa14a91e44ac74
Author: huangyiming <huangyimingha...@163.com>
AuthorDate: Mon Sep 28 10:16:17 2020 +0800

    KAFKA-10502: Use Threadlocal.remote to avoid leak on TimestampRouter (#9304)
    
    Reviewers: Guozhang Wang <wangg...@gmail.com>
---
 .../main/java/org/apache/kafka/connect/transforms/TimestampRouter.java  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/connect/transforms/src/main/java/org/apache/kafka/connect/transforms/TimestampRouter.java
 
b/connect/transforms/src/main/java/org/apache/kafka/connect/transforms/TimestampRouter.java
index 78384df..388a7b9 100644
--- 
a/connect/transforms/src/main/java/org/apache/kafka/connect/transforms/TimestampRouter.java
+++ 
b/connect/transforms/src/main/java/org/apache/kafka/connect/transforms/TimestampRouter.java
@@ -91,7 +91,7 @@ public class TimestampRouter<R extends ConnectRecord<R>> 
implements Transformati
 
     @Override
     public void close() {
-        timestampFormat = null;
+        timestampFormat.remove();
     }
 
     @Override