Hi Kafkas! Reading through the documentation and code of Kafka, it seems there is no feature to set flushing interval (messages/time) for a specific topic. I am interested in this to get consistency for certain topics by flushing after every message, while having eventual consistency for other topics (default).
Would there be interest in such feature? Then I might be curious to give the Log module a dive and see if I can foster enough Scala to add this. Thanks! -- Simon http://sirupsen.com/