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

>>阅读原文<<