反応型カフカコネクタを使用して、Kafka と Akka Streams のプロジェクトに取り組んでいます。Reactive-kafka は独自のディスパッチャ (akka.kafka.default-dispatcher) を使用することがわかりましたが、その場合、デフォルトの akka ディスパッチャを使用すると、すべてが高速になります (reactive-kafka ディスパッチャ ~300 メッセージ/秒、デフォルトのディスパッチャ) ~1300 メッセージ/秒)
デフォルトのディスパッチャーを使用するのが安全かどうか疑問に思います。
前もって感謝します。
いいえ、Akka のデフォルトのディスパッチャは使用しないでください。基礎となる Kafka クライアントはブロッキングを使用するため、アクター システム全体が機能しなくなる可能性があります。
代わりに、akka.kafka.default-dispatcher(設定に追加akka.kafka.default-dispatcher.thread-pool-executor.fixed-pool-size = 32するなどして) を再構成するか、独自のディスパッチャーをより適切に構成して、それを必要とする Alpakka Kafka コネクタ コンシューマーに使用することができます。
ディスパッチャーの設定方法については、 Akka ディスパッチャーを参照してください。