spark-streaming消费kafka写入hbase踩坑实战

场景 otter同步mysql的数据到kafka，spark-streaming消费kafka，采用motator异步写hbase。mysql的insert，update，delete特别频繁，每秒都有大量的insert，delete，update   以下都是基于同一条数据操作 1.  坑 Delete(byte [] row), Put(byte[] row)， bufferedmutator

>>阅读原文<<