streaming - 具有默认调度程序的响应式(Reactive)卡夫卡？

Question

我正在一个使用 Kafka 和 Akka Streams 的项目 reactive-kafka连接器。我们发现reactive-kafka使用它自己的调度程序(akka.kafka.default-dispatcher)，但是如果我们使用默认的akka​​调度程序，一切都会更快(reactive-kafka调度程序〜300条消息/秒，默认调度程序~1300 条消息/秒)

我想知道使用默认调度程序是否安全。

提前致谢。

Answer 1

不，你不应该使用 Akka 的默认调度程序。由于底层 Kafka 客户端使用阻塞，它可能会阻止整个 Actor 系统运行。

相反，您可以重新配置akka.kafka.default-dispatcher(例如，通过添加akka.kafka.default-dispatcher.thread-pool-executor.fixed-pool-size = 32 到您的设置)，或者更好地配置您自己的调度程序并将其用于需要它的 Alpakka Kafka 连接器使用者。

参见Akka dispatchers了解如何配置调度程序。