SparkStreaming——基于Kafka消费到HBase的顺序问题

线上设置的Kafka默认配置是3个Partition，设我们传递的数据是用户的信息如下 用户id 用户名 具体信息 动作 001 zhangsan … 插入 001 zhangsan … 修改 001 zhangsan … 删除 002 lisi … 插入 生产者分别向不同的主Partition发送数据，消费者每5秒去消费数据，因为Kafka是全局无序且局部数据有序，所以可能会出现的结果是这样的：

>>阅读原文<<