flink sink kafka exception

[董鹏 <do...@imdada.cn>]

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