【Flink】Flink 消费kafka报错 AMRMClientAsyncImpl Interrupted while waiting for queue InterruptedException1.背景 1.背景 一个flink etl程序,读取一个kafka集群的数据,到两外一个集群,然后报错