Closed joestein closed 9 years ago
The current producer is async however ultimately there is only one sync producer for that one async queue. If we use Akka http://doc.akka.io/docs/akka/2.2.3/java.html we can have multiple async (which are bound by a sync) producers. The dispatcher should be configurable but default to the round robin dispatcher. Something like how we do it in Scala https://github.com/stealthly/scala-kafka/blob/master/src/main/scala/AkkaKafka.scala with a better initialization.
The current producer is async however ultimately there is only one sync producer for that one async queue. If we use Akka http://doc.akka.io/docs/akka/2.2.3/java.html we can have multiple async (which are bound by a sync) producers. The dispatcher should be configurable but default to the round robin dispatcher. Something like how we do it in Scala https://github.com/stealthly/scala-kafka/blob/master/src/main/scala/AkkaKafka.scala with a better initialization.