flink sink kafka exception

Tue, 19 Feb 2019 23:09:15 -0800 

flink大神，你们好。flink sink kafka 
遇到这个异常，不影响job运行，不影响结果，偶尔抛出。向你们请教一下，希望获取些思路。2019-02-20 10:08:46.889 +0800 
[Source: rn -> Flat Map -> async wait operator -> async wait operator -> Sink: 
Unnamed (17/20)] ERROR [org.apache.flink.streaming.runtime.tasks.StreamTask] 
[StreamTask.java:481] - Error during disposal of stream operator. 
org.apache.kafka.common.KafkaException: Failed to close kafka producer      at 
org.apache.kafka.clients.producer.KafkaProducer.close(KafkaProducer.java:734)   
     at 
org.apache.kafka.clients.producer.KafkaProducer.close(KafkaProducer.java:682)   
     at 
org.apache.kafka.clients.producer.KafkaProducer.close(KafkaProducer.java:661)   
     at 
org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducerBase.close(FlinkKafkaProducerBase.java:319)
    at 
org.apache.flink.api.common.functions.util.FunctionUtils.closeFunction(FunctionUtils.java:43)
        at 
org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator.dispose(AbstractUdfStreamOperator.java:117)
       at 
org.apache.flink.streaming.runtime.tasks.StreamTask.disposeAllOperators(StreamTask.java:477)
         at 
org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:378) 
     at org.apache.flink.runtime.taskmanager.Task.run(Task.java:711)         at 
java.lang.Thread.run(Thread.java:748) Caused by: 
java.lang.InterruptedException: null        at java.lang.Object.wait(Native 
Method)         at java.lang.Thread.join(Thread.java:1260)      at 
org.apache.kafka.clients.producer.KafkaProducer.close(KafkaProducer.java:703)   
     ... 9 common frames omitted

回复