我覺(jué)得樓主的思路沒(méi)毛病。
發(fā)現(xiàn)kafka丟消息后的排查背景： 最近在用kafka做消息中間件，producer從hive中讀取消息發(fā)送到kafka，后端storm對(duì)消息分類(lèi)發(fā)送到elasticsearch建立索引。 問(wèn)題：...
發(fā)簡(jiǎn)信
IP屬地：上海
我覺(jué)得樓主的思路沒(méi)毛病。
發(fā)現(xiàn)kafka丟消息后的排查背景： 最近在用kafka做消息中間件，producer從hive中讀取消息發(fā)送到kafka，后端storm對(duì)消息分類(lèi)發(fā)送到elasticsearch建立索引。 問(wèn)題：...