ExecutionContextとblockingについて調べたメモ [scala] - だいたいよくわからないブログ の続きです。 今回の記事の結論 blockingをたくさん呼ぶとOOMになるまでスレッド数が増え続けるっぽい。 ==> 追記: scala2.12 だとlimitがあるので安心して使えるらし…

気になったのでコードを追ったりしてみました。備忘録けんメモ書きです。 そもそもtimeoutがどうやって送信されてどうやってbrokerで受信されているのかが追いにくいのですが、 https://github.com/apache/kafka/blob/0.9.0.0/clients/src/main/java/org/apa…

概ね Mailbox with Explicit Acknowledgement — Akka Documentation のお話です。 まずはbuild.sbtです。 name := "akka-scala-seed" version := "1.0" scalaVersion := "2.11.8" val akkaVersion = "2.4.8" libraryDependencies ++= Seq( "com.typesafe.akk…