并行使用Akka Streams Kafka Producer

Question

我想并行化写入kafka，即有多个生产者将数据发送到kafka，尽管它来自akka流。在其他我的流中有几个从源头开始的阶段，然后在发送数据时，我希望有大约16位工作人员同时发送数据。

我想知道是否需要在阿卡流图DSL中嵌入Akka Streams Kafka并为此使用平衡器，或者如果有更简单的解决方案。另外，简单地说，如果有人做了这样的事情总的来说会很棒。

Answer 1

阿卡流卡夫卡（又名无卡夫卡）已经得到了制片并行特定设置（见docs）

akka.kafka.producer { 
    # Tuning parameter of how many sends that can run in parallel. 
    parallelism = 100 

    ... 
} 

你试过调整它来解决问题了吗？