0
我面臨的一個奇怪的問題,在我的製片代碼卡夫卡producer.close()不執行代碼之後
producer.flush();
logger.info("Closing producer");
producer.close();
logger.info("successfully closed producer");
我上面的代碼片斷作爲守則的一部分,問題是,我只能看到以下輸出
Closing producer
在我的日誌中,最後一行沒有出現。 如果我註釋掉producer.close()它確實出現在日誌中。 任何想法,爲什麼這樣?
主題名稱是測試。它沒有任何特殊字符 –