有没有参考flink官方源码示例中的这个例子： org.apache.flink.addons.hbase.example.HBaseWriteExample 这个类写的就是flink插入HBase 效率很高 我们实际生产也用到了插入HBase但是效率很高，你可以看一下这个源码;
张作峰 <m...@zhangzuofeng.cn> 于2019年4月6日周六 下午4:38写道： > 业务场景中，需要将处理后的消息写入到HBase中，由于写入HBase慢，引起消息堆积。 > 通过Stream API 有没有方法可以异步批量发送？ > 谢谢！
