反应式-使用默认调度程序的kafka？

Question

我正在与卡夫卡和阿卡流使用reactive-kafka连接器的项目。我们已经发现reactive-kafka使用它自己的dispatcher (akka.kafka.default- dispatcher )，但是，如果我们使用默认的akka dispatcher，一切都会更快(reactive-kafka dispatcher ~300 messages/s，default dispatcher ~1300 messages/s )

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

提前谢谢。

Answer 1

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

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

有关如何配置调度程序的信息，请参阅Akka dispatchers。