使用具有规模的nodejsstream式传输cassandra数据

我有一个要求使用nodejs读取存储在cassandra中的数百万条logging。

我已经准备好了stream式nodejs服务，可以从cassandrastream中读取数据stream，并将数据推送到分析服务器（再次使用stream式服务）。

但是，我不确定如何实现nodejs层的横向扩展，其中nodejs应用程序的多个实例从cassandra没有DUPLICATION读取并将其提供给分析服务器。

任何帮助，这将有很大的帮助。

谢谢。