背景: 最近在用kafka做消息中间件,producer从hive中读取消息发送到kafka,后端storm对消息分类发送到elasticsearch建立索引。 问题:...
IP属地:天津
背景: 最近在用kafka做消息中间件,producer从hive中读取消息发送到kafka,后端storm对消息分类发送到elasticsearch建立索引。 问题:...
首先我们做一个模拟,执行以下的sql,其中有如下图数据: 时间会话1会话2会话31begin;select * from t_student where id = 22upd...