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