scala - Akka ストリームの actor-conflation-ratelimit-actor が最初のいくつかのメッセージをドロップする (ときどき)

Question

単純なコンフレート コンボ (以下) は、staartup でデバッグ メッセージを出力し、需要がないためにメッセージをドロップしていることを示すことがあります。私は合成段階が無限の需要を提供することを期待するので、上記は決して当てはまらない. 私は何が欠けていますか？

val sourceRef = Source.actorRef[KeyedHighFreqEvent](0, OverflowStrategy.fail)
.conflateWithSeed(...into hash map...)
.throttle(8, per = 1.second, maxBurst=24, ThrottleMode.shaping)
.mapConcat(...back to individual KeyedHighFreqEvent...)
.groupedWithin(1024, 1.millisecond)
.to(Sink.actorRef(networkPublisher, Nil))
.run()

system.eventStream.subscribe(sourceRef, classOf[KeyedHighFreqEvent])