Wie kann man die langsame Leistung von reaktiven Kafka (Scala plus Akka Streams) verbessern?

Ich bewege mein Projekt von RabbitMQ nach Kafka und versuche zu verstehen, wie schnell reaktives Kafka sein wird.

Ich bin derzeit in der Lage, etwa 12K / sec triviale Nachrichten / Sek. in Rabbit zu schreiben, und beim Lesen einen trivialen Pull aus der Warteschlange durch einen "Hello World" -Stream mit etwa 4 K / Sek.

Ich bin mit reaktiven Streams nach Kafka gezogen, ich kann vielleicht 1M / sec schreiben - großer Gewinn! Aber in der gleichen Umgebung kann ich nur etwa 2K / sec durch den Stream fließen, indem ich den Ansatz in den Beispielen hier benutze: DummyConsumer.scala

Weiß jemand Tipps, wie ich das Lesen wieder auf Niveaus bringen könnte, die mit dem Rabbit-Ansatz vergleichbar sind?

Interessant: Ich habe es gerade "direkt" versucht (über die rohen Java-Treiber gegen reactive-kafka auf Kafka zugegriffen) und bekomme ungefähr 22K Lesezugriff, das ist also ziemlich gut. Es scheint etwas darüber zu sein, wie ich reaktive Kafka benutze, verlangsamt die Dinge waaay.

Ok ... Ich jage dieses Ding. Als nächstes habe ich einen rohen Akka-Stream "Hallo Welt" versucht:

Das lief mit sehr schnellen 742K / sec! Kafka rohe ist also schnell und Akka-Streams sind schnell. Also ist der Schuldige irgendwo in der Frage, wie reaktives Kafka gebaut wird (oder wahrscheinlicher), wie ich versuche, es zu benutzen. Unter Berücksichtigung von Reibung sollte ich erwarten, etwas in der Nähe von 22 K / Sek. Hmm.