問題:kafka的producer不調用.close()方法

問題:kafka的producer不調用.close()方法 在學習使用kafka過程中,程序執行到producer.close()時卡住很久,一段時間後會停止,但是kafka消費者仍然沒消費到信息,求解答。 close上面是用一個for循環send(new ProducerRecord(。。。))對象把數據發往目標topic,這一步執行完了,到close()就停住,來一個高手解答一下如何解決。
相關文章
相關標籤/搜索