背景： 最近在用kafka做消息中间件，producer从hive中读取消息发送到kafka，后端storm对消息分类发送到elastic...