2017-07-13 38 views
0

我面臨的一個奇怪的問題,在我的製片代碼卡夫卡producer.close()不執行代碼之後

producer.flush(); 
logger.info("Closing producer"); 
producer.close(); 
logger.info("successfully closed producer"); 

我上面的代碼片斷作爲守則的一部分,問題是,我只能看到以下輸出

Closing producer 

在我的日誌中,最後一行沒有出現。 如果我註釋掉producer.close()它確實出現在日誌中。 任何想法,爲什麼這樣?

回答

0

生產者話題的名稱是什麼?我問,因爲據我所知有一個當前打開的bug阻止客戶端線程,如果主題名稱包含單引號。你可以檢查嗎?

+0

主題名稱是測試。它沒有任何特殊字符 –