背景： 最近在用kafka做消息中間件更振，producer從hive中讀取消息發(fā)送到kafka煤搜，后端storm對(duì)消息分類發(fā)送到elastic...