kafka-flink-hbase
kafka-flink-hbase copied to clipboard
map中使用Hbase连接池的问题
您好,我看了您的代码,有一个疑问。 transction.rebalance().map 请问在这里面用连接池的方式是否有问题,当kafka数据量很大的时候,会开大量的hbase connection,会不会把hbase连接池撑爆?这里可以用mapPartition 函数吗?