使用Alpakka连接器的多个使用者线程 - java

我正在使用Alpakka kafka连接器来消耗来自kafka的数据包。我正在使用Consumer作为CommittableSource。我想在一台计算机上创建多个使用者线程，并将它们用作单个源。我该如何实现？ 当前，我已经使用Consumer.CommittableSource创建了多个源，并使用“合并”功能将所有源合并为一个源。但是我不确定这是否是正确的 […]