【kafka】kafka Selector unexpected error closing connection

1.場景1

1.1 概述

flink消費kafka報錯

org.apache.kafka.common.errors.TimeoutException: Timeout of 60000ms expired before the position for partition user_all_debezium-0 could be determined

           

請問flink本機可以連接配接kafka、但是仍到測試環境就連不上

idea跑是正常得，打包仍上去，不報錯，運作幾分鐘後就是上面得的異常

每條Kafka的資料大小不大。