reactive-kafka与默认调度程序？

Question

我正在与Kafka和Akka Streams合作使用reactive-kafka连接器.我们发现reactive-kafka使用它自己的调度程序(akka.kafka.default-dispatcher),但是如果,实例,我们使用默认的akka​​调度程序,一切都更快(reactive-kafka dispatcher~300 messages/s,默认调度程序) ~1300条消息/ s)

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

提前致谢.

Answer 1

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

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

有关如何配置调度程序,请参阅Akka调度程序.