java - Java/Scala 流时间序列数据

Question

我有基于 HBase (OpenTSDB) 的底层时间序列数据库，在它之上，我的应用程序以某种方式从 HBase 加载数据。我需要将此获取的时间序列流式传输到应用程序客户端。什么是最好的解决方案？如果客户端暂停处理已经收到的数据，服务器也应该暂停，如果客户端死了，服务器应该停止发送数据。

我想要一个纯 Java 解决方案。我知道 ZMq，但对它没有很好的体验。也许我应该看看Netty？

PS 数据量足够大。每个对服务器的请求数千兆字节和数十千兆字节。