我們用的時(shí)候遇到這個(gè)報(bào)錯(cuò)是因?yàn)閠opic不存在,但是我們的kafka配置了自動(dòng)生成topic,所以這個(gè)報(bào)錯(cuò)后來就不管了。
kafka java 生產(chǎn)消費(fèi)程序demo示例kafka是吞吐量巨大的一個(gè)消息系統(tǒng),它是用scala寫的,和普通的消息的生產(chǎn)消費(fèi)還有所不同,寫了個(gè)demo程序供大家參考。kafka的安裝請(qǐng)參考官方文檔。 首先我們需要新建...